Damian Guy created KAFKA-3835: --------------------------------- Summary: Streams is creating two ProducerRecords for each send via RecordCollector Key: KAFKA-3835 URL: https://issues.apache.org/jira/browse/KAFKA-3835 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.10.0.0 Reporter: Damian Guy Assignee: Guozhang Wang Priority: Minor Fix For: 0.10.1.0
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 could be removed by having the calling code create the correct ProducerRecord, i.e, by serializing the key & value with the serializers and assigning the partition. The caller already has all of the information it needs {code} public <K, V> void send(ProducerRecord<K, V> record, Serializer<K> keySerializer, Serializer<V> valueSerializer, StreamPartitioner<K, V> partitioner) {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)