Minor Description
The RecordCollector.send(..) method below, currently receives a ProducerRecord from its caller and then creates another one to forward on to its producer. The creation of 2 ProducerRecords should be removed.
public <K, V> void send(ProducerRecord<K, V> record, Serializer<K> keySerializer, Serializer<V> valueSerializer,
StreamPartitioner<K, V> partitioner)
We could replace the above method with
public <K, V> void send(String topic, K key, V value, Integer partition, Long timestamp, Serializer<K> keySerializer, Serializer<V> valueSerializer, StreamPartitioner<K, V> partitioner)
Attachments
Issue Links
- links to
