Description
New producer hardcodes the serializers:
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.ByteArraySerializer") props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.ByteArraySerializer")
And thus cannot be overridden from the commandline argument -key-serializer or -value-serializer
Attachments
Issue Links
- duplicates
-
KAFKA-2526 Console Producer / Consumer's serde config is not working
- Open