[NIFI-2515] Setting key.serializer in publish kafka leads to org.apache.kafka.common.errors.SerializationException

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.0.0-Beta
• Fix Version/s: 1.0.0, 0.7.1
• Component/s: Extensions
• Assignee: Oleg Zhurakousky
• Reporter: Arpit Gupta
• Created: 08/Aug/16 16:26
• Updated: 07/Oct/16 19:01
• Resolved: 09/Aug/16 18:34

Description

If one sets key.serializer in the publish kafka processor we see error

4895-9b14-9e8b1d88755e}, body={topics=[putMessages-83cf2948-b110-2016-08-07 17:11:56,191 ERROR [Timer-Driven Process Thread-7] o.a.n.p.kafka.pubsub.PublishKafka PublishKafka[id=65fd2baf-0156-1000-ffff-fffff6bf89be] PublishKafka[id=65fd2baf-0156-1000-ffff-fffff6bf89be] failed to process due to org.apache.kafka.common.errors.SerializationException: Can't convert key of class [B to class org.apache.kafka.common.serialization.IntegerSerializer specified in key.serializer; rolling back session: org.apache.kafka.common.errors.SerializationException: Can't convert key of class [B to class org.apache.kafka.common.serialization.IntegerSerializer specified in key.serializer

Issue Links

• links to: GitHub Pull Request #814