有没有办法去查询Kafka去知道哪个分区被分配给当前的消费者?背景是希望将分配给每个消费者的分区的统计信息发送给prometheus,并在自动重新平衡过程中自动将分区移动到另一个消费者时从统计信息中删除分区。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!