根据Kafka文件:
生产者负责选择将哪个消息分配给主题中的哪个分区.
因此我的主要问题是:
如何使用kafka-console-producer.sh(或Kafka Java客户端)将消息发送到所选分区?
我想在消息发送时指定某种"分区ID".可能这样的"分区ID"存储在Zookeeper中的某个地方.你知道哪一个值(在Zookeeper中)识别Kafka分区吗?