Hello Srikanth, The GetKafka Processor should be retrieving the value of a message from Kafka as a sequence of bytes and adding whatever it receives as the content of the FlowFile. It does not attempt to interpret it as a String.
The key of the message, if any, is added as a FlowFile attribute, and as a result must be interpreted as a String. Is it the message key that is encoded as Avro, or the value of the message? Is there any chance that you have a sample file that we could use to test with, to see if we can replicate the problem? Thanks -Mark ________________________________ > From: [email protected] > Date: Sun, 30 Aug 2015 19:42:39 -0400 > Subject: Kafka+Avro processor chain > To: [email protected] > > Hello, > > I have a Kafka topic with Avro encoded data. Looks like GetKafka > returns content decoded as String. > Is there a way to get bytes from GetKafka so that I can pass it on to a > custom AvroDecoder processor? > > Thanks, > Srikanth
