Description
Since the new ser/de interfaces use a configure() method with an extra isKey parameter, they need to manually configured after creation since getConfiguredInstances can't invoke configure() for us. The new consumer is missing this step when the deserializer is instantiated automatically by the consumer.
Attachments
Attachments
Issue Links
- is superceded by
-
KAFKA-2121 prevent potential resource leak in KafkaProducer and KafkaConsumer
- Resolved