根据Kafka文档：
生产者负责选择要分配给主题中哪个分区的消息。
如何使用kafka-console-producer.sh将消息发送到选定的分区？
我想在邮件发送时指定某种“分区ID”。
最佳答案
更新：这个答案在2014年是正确的，但是更多当前版本的Kafka可以通过控制台生产者生成键/值对。请参见below answers
kafka-console-producer.sh不支持开箱即用地向特定分区生成消息。
但是，更新脚本以传递额外的分区ID参数然后在自定义分区中对其进行处理应该非常简单，如@Chiron在kafka.tools.ConsoleProducer类的修改版本中所描述的那样。
在以下位置查看源代码：
https://apache.googlesource.com/kafka/+/refs/heads/trunk/bin/kafka-console-producer.sh
https://apache.googlesource.com/kafka/+/refs/heads/trunk/core/src/main/scala/kafka/tools/ConsoleProducer.scala
关于apache-kafka - 如何使用kafka-console-producer将消息生成到所选分区？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26553412/