[
https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13726576#comment-13726576
]
Guozhang Wang commented on KAFKA-967:
-
Jun, before this patch each message will use a
[
https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13725381#comment-13725381
]
Jun Rao commented on KAFKA-967:
---
Thanks for the patch. We probably should only set the key if
[
https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13710046#comment-13710046
]
Guozhang Wang commented on KAFKA-967:
-
4. Change key type from Integer to ByteArray in
[
https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13710589#comment-13710589
]
Joel Koshy commented on KAFKA-967:
--
+1 - thanks for the patch.
Use key
