首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

kafka中partition和消费者对应关系

.properties 消费者数量为2大于partition数量1,此时partition和消费者进程对应关系如下: bin/kafka-consumer-groups.sh --bootstrap-server...kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test2 开始时,在g3...发送消息1,2,3,4,5,6,7,8,9 C1接收到1,3,4,6,7,9 C2接收到2,5,8 此时P1、P2对对应C1,即多个partition对应一个消费者,C1接收到消息量是C2的两倍 然后,在g3...如上图,向test2发送消息1,2,3,4,5,6,7,8,9 消息被g3组的消费者均分,g4组的消费者在接收到了所有的消息。...g3组: C1接收到了:2,5,8 C2接收到了:3,6,9 C3接收到了:1,4,7 g4组: C1接收到了:1,2,3,4,5,6,7,8,9 启动多个组,则会使同一个消息被消费多次

2.7K21
领券