kafka10消费者(重新)加入组

v09wglhw  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(261)

我有一个40个分区的主题,并计划在每个vm中运行10个消费者(总共4个vm)。
当我在一个4核的vm中启动一个有10个消费者的进程时,它会像预期的那样工作。但是,当我开始在一个2核的虚拟机中使用10个消费者时,我不断地得到下面的信息,然后它就停在那里了。它甚至不消耗一条消息。

INFO  : loggerName="o.a.k.c.c.i.ConsumerCoordinator" threadName="group1" txnId="" Revoking previously assigned partitions [topic1] for group group1
INFO  : loggerName="o.a.k.c.c.i.AbstractCoordinator" threadName="default-dispatcher-9" txnId="" (Re-)joining group group1

但是这在2核机器中有5个用户的情况下运行良好。
谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题