相关疑难解决方法(0)

根据Kafka文件:

生产者负责选择将哪个消息分配给主题中的哪个分区.

因此我的主要问题是:

如何使用kafka-console-producer.sh(或Kafka Java客户端)将消息发送到所选分区？

我想在消息发送时指定某种"分区ID".可能这样的"分区ID"存储在Zookeeper中的某个地方.你知道哪一个值(在Zookeeper中)识别Kafka分区吗？