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

[Arpit Gupta (JIRA)]

Arpit Gupta created NIFI-2412:
---------------------------------

             Summary: 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: Bug
          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)