[jira] [Commented] (NIFI-2412) Allow user to set serializer and de serializer in publish and consume kafka processors

["Oleg Zhurakousky (JIRA)" <ji...@apache.org>]

    [ 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)