Hi,
Its not encoding issue. I am not able to figure out how to read Kafka key
itself.
eg.
Kafka key = {type: foo, meta: etc, etc }
Kafka message = {Avro Payload}I want to use RouteOnAttribute processor based on type = foo or bar. For this to happen, I need to extract value foo from Kafka.key to flow file. Basically I am not able to figure out how to read key and extract attributes from it from Kafka message in nifi. Could you suggest me something here. Thanks On 2018/11/23 15:14:53, Mike Thomsen <m...@gmail.com> wrote: > If you are having encoding-related issues with reading that attribute, try> > switching to the Kafka string serializer in your producer.> > > On Fri, Nov 23, 2018 at 10:12 AM ashwin konale <as...@gmail.com>> > wrote:> > > > Hi,> > > I have key-value pair of avro messages in kafka topic I want to consume> > > from. I can easily do modifications on message value using nifi> > > consumeKafkaRecord processor, but it doesnt show key of the message.> > > ConsumeKafka processor has kafka.key attribute but I am not sure how to> > > read its contents(Since it is avro encoded) and add certain values as> > > attributes to flowfile. Any pointers will be much helpful.> > >> > > Thanks> > >> >
smime.p7s
Description: S/MIME cryptographic signature
