[KAFKA-13864] Change the visibility of a KafkaProducer and KafkaConsumer constructor

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Won't Do
• Affects Version/s: 3.1.0
• Component/s: clients
• Assignee: François Rosière
• Reporter: François Rosière
• Created: 30/Apr/22 20:22
• Updated: 18/May/22 20:06
• Resolved: 18/May/22 07:20

Description

To allow implementing Spring managed interceptors for producers and consumers,

https://github.com/spring-projects/spring-kafka/issues/2244

The following changes should be applied in Kafka

1. Create 2 new constructors in KafkaProducer

public KafkaProducer(ProducerConfig config)
public KafkaProducer(ProducerConfig config, Serializer<K> keySerializer, Serializer<V> valueSerializer) 

2. Create a new constructor + increase the visibility of an existing constructor in KafkaConsumer

public KafkaConsumer(ConsumerConfig config)
public KafkaConsumer(ConsumerConfig config, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer)

3. Create 2 new constructors in TopologyTestDriver

public TopologyTestDriver(Topology topology, StreamsConfig config)
public TopologyTestDriver(Topology topology, StreamsConfig config, Instant initialWallClockTime) 

 More details can be found in the related KIP

https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211882578

 

Issue Links

• contains: KAFKA-7527 Enable Dependency Injection for Kafka Streams handlers (KIP-378)
• Is contained by: KAFKA-13913 Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams
• links to: GitHub Pull Request #12125