...
To allow implementing Spring managed interceptors for producers and consumers, both, the KafkaProducer and the KafkaConsumer should expose a constructor constructors taking a config instance (ProducerConfig and ConsumerConfig) instead of a configuration given as a Properties or as a Map.
...
KafkaConsumer
Proposed Changes
Create a 2 new constructor constructors in KafkaProducer
Code Block | ||||
---|---|---|---|---|
| ||||
public KafkaProducer(ProducerConfig config)
public KafkaProducer(ProducerConfig config, Serializer<K> keySerializer, Serializer<V> valueSerializer) |
and create a new constructor + increase the visibility of an existing constructor in KafkaConsumer
Code Block | ||||
---|---|---|---|---|
| ||||
public KafkaConsumer(ConsumerConfig config)
public KafkaConsumer(ConsumerConfig config, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer) |
...