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

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7.0
• Fix Version/s: 1.0.0, 0.7.1, 1.0.0-Beta
• Component/s: Extensions
• Assignee: Oleg Zhurakousky
• Reporter: Arpit Gupta
• Created: 27/Jul/16 20:45
• Updated: 07/Oct/16 22:09
• Resolved: 05/Aug/16 21:23

Description

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.