Created 03-22-2019 10:19 PM
Team,
I have a scenario where my kafka messages(from same topic) are flowing through single enrichment pipeline and written at the end into HDFS and MongoDB. My Kafka consumer for HDFS will run on hourly basis. So I need to know the best possible way to route flowfiles to putHDFS and putMongo based on which consumer it is coming from.
Thanks