只是为了使场景简单。
消费者数量 == 分区数量 == Kafka 代理数量
如果将消费者部署在broker所在的同一台机器上，如何让每个消费者只在本地消费消息？目的是减少所有网络开销。
我认为如果每个消费者都可以知道他们机器上的 partition_id，我们就可以做到，但我不知道怎么做？或者有其他方向可以解决这个问题吗？
谢谢。
bin/kafka-topics.sh --zookeeper [zk address] --describe --topic [topic_name]告诉您哪个代理托管每个分区的领导者。然后，您可以为每个消费者使用手动分区分配，以确保它从本地分区消费。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句