...
Create a new constructor in KafkaProducer
Code Block | ||||
---|---|---|---|---|
| ||||
public KafkaProducer(ProducerConfig config, Serializer<K> keySerializer, Serializer<V> valueSerializer) |
and increase the visibility of an existing constructor in KafkaConsumer
Code Block | ||||
---|---|---|---|---|
| ||||
public KafkaConsumer(ConsumerConfig config, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer) |
...