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

["Arpit Gupta (JIRA)" <ji...@apache.org>]

Arpit Gupta created NIFI-2515:
---------------------------------

             Summary: Setting key.serializer in publish kafka leads to org.apache.kafka.common.errors.SerializationException
                 Key: NIFI-2515
                 URL: https://issues.apache.org/jira/browse/NIFI-2515
             Project: Apache NiFi
          Issue Type: Bug
          Components: Extensions
    Affects Versions: 1.0.0-Beta
            Reporter: Arpit Gupta


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

{code}
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
{code}




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)