前提是我有一个分配了分区的kafka消费者( assign
而不是 subscribe
),是否可以通知主题是否使用新分区进行缩放?我想把新的分区也分配给它。我正在使用javaapi。
如果我理解正确,重新平衡不仅发生在消费者加入或离开一个组时,而且也发生在分区数量改变时。
pps公司。我不想使用 subscribe
因为我不想使用组成员身份或提交偏移量,并且希望在代理上留下尽可能少的痕迹。
前提是我有一个分配了分区的kafka消费者( assign
而不是 subscribe
),是否可以通知主题是否使用新分区进行缩放?我想把新的分区也分配给它。我正在使用javaapi。
如果我理解正确,重新平衡不仅发生在消费者加入或离开一个组时,而且也发生在分区数量改变时。
pps公司。我不想使用 subscribe
因为我不想使用组成员身份或提交偏移量,并且希望在代理上留下尽可能少的痕迹。
暂无答案!
目前还没有任何答案,快来回答吧!