ConsumeKafka vs getKafka

2016-07-17 Thread Sumanth Chinthagunta
Env: Linux , Kafka 9.0.x, NiFi: 0.7 We like to use new ConsumeKafka processor but found critical limitations compared to old getKafka processor. New ConsumeKafka is not writing critical Kafka attributes i.e., kafka.key, kafka.offset, kafka.partition etc into flowFile attributes. Old getKa

Re: ConsumeKafka vs getKafka

2016-07-17 Thread Oleg Zhurakousky
Sumo Thank you for pointing this out. Very valid comments and just in time for the upcoming 1.0 release. Would you mind to raise a JIRA and we'll address it promptly? Cheers Oleg > On Jul 17, 2016, at 16:38, Sumanth Chinthagunta wrote: > > Env: Linux , Kafka 9.0.x, NiFi: 0.7 > > We like

Re: ConsumeKafka vs getKafka

2016-07-17 Thread Sumanth Chinthagunta
Done. https://issues.apache.org/jira/browse/NIFI-2298 Thanks -Sumo > On Jul 17, 2016, at 1:37 PM, Sumanth Chinthagunta wrote: > > Env: Linux , Kafka 9.0.x, NiFi: 0.7 > > We like to use new ConsumeKafka processor but found critical limitati