[
https://issues.apache.org/jira/browse/NIFI-2515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15412467#comment-15412467
]
ASF GitHub Bot commented on NIFI-2515:
--------------------------------------
GitHub user olegz opened a pull request:
https://github.com/apache/nifi/pull/814
NIFI-2515 fixed Kafka serialization/deserialization settings
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/olegz/nifi NIFI-2515B
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/nifi/pull/814.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #814
----
commit 22c3f9e1996ff4869cc3fabe584c451094bc0431
Author: Oleg Zhurakousky <[email protected]>
Date: 2016-08-08T21:03:12Z
NIFI-2515 fixed Kafka serialization/deserialization settings
----
> 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
> Assignee: Oleg Zhurakousky
> Priority: Minor
> Fix For: 1.0.0, 0.8.0
>
>
> 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)
