[
https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13702667#comment-13702667
]
Guozhang Wang commented on KAFKA-957:
-------------------------------------
The proposed design is the following:
1. Keep the ProducerDataChannel for non-keyed messages.
2. For each message in the consumers' stream, check if its key is null:
2.1. If yes, put it directly to the ProducerDataChannel.
2.2. If not, select the producer based on the key's hash value, and call the
send function of that producer directly (would possibly block).
Patch will be available once the system tests are passed.
> MirrorMaker needs to preserve the key in the source cluster
> -----------------------------------------------------------
>
> Key: KAFKA-957
> URL: https://issues.apache.org/jira/browse/KAFKA-957
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8
> Reporter: Jun Rao
> Assignee: Guozhang Wang
>
> Currently, MirrorMaker only propagates the message to the target cluster, but
> not the associated key.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
