[
https://issues.apache.org/jira/browse/NIFI-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15396048#comment-15396048
]
Oleg Zhurakousky commented on NIFI-2412:
----------------------------------------
[~joewitt] and all.
This is a trivial fix. Basically now we are hard coding serializers and the
change would make them being pulled form Dynamic Properties as it is standard
Kafka property. so very simple.
Could go to 1.0, but it could also wait for 1.1. Thoughts?
> Allow user to set serializer and de serializer in publish and consume kafka
> processors
> --------------------------------------------------------------------------------------
>
> Key: NIFI-2412
> URL: https://issues.apache.org/jira/browse/NIFI-2412
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Extensions
> Affects Versions: 0.7.0
> Reporter: Arpit Gupta
>
> Publish kafka today sets key and value serializer to class
> org.apache.kafka.common.serialization.ByteArraySerializer
> Even if the user passes different values in the processor config they get
> overwritten.
> We should allow dynamic values for serializer and de serializer as needed.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
