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)
