扩展kafka消费者,并将其分布在app server的多个节点上

bzzcjhmw  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(117)

我们有运行在appserver上的java应用程序。
我们有5个分区的主题1。我们在消费者组“consumergroup1”中创建了5个消费者线程。每个分区一个使用者线程。它们正在appserver 1上运行。
现在我们在另一个节点上再打开一个app server servertwo。
我们希望在新服务器上为topic1运行同一组“consumergroup1”中的一些使用者。基本上是在同一用户组的两个应用服务器之间分配用户线程。
如果我们为consumergroup1在服务器2上调出使用者,它们将是冗余的,因为已经有5个使用者线程在服务器1上运行,这等于topic1中的总分区数
有人能建议如何跨多个appservers节点重新分配使用者线程吗。应用服务器节点根据需求进行缩放

暂无答案!

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

相关问题