我想阻止Kafka的客户创建他们自己的消费群体,而不是加入现有的消费群体之一。有没有可能通过Kafkaacl强制执行?
dw1jzc5e1#
不,没有直接的api/命令来阻止kafka消费者创建新的消费者组。如果您想让您的消费者加入现有的组,您应该提到组名。这就是多个消费者应该能够从同一个主题消费,但使用不同的消费群体id的整个想法。如果仍要这样做,则需要添加自定义逻辑。首先,您应该迭代消费者组并提取该主题的现有消费者组名称,然后传递给下一个消费者。
1条答案
按热度按时间dw1jzc5e1#
不,没有直接的api/命令来阻止kafka消费者创建新的消费者组。如果您想让您的消费者加入现有的组,您应该提到组名。
这就是多个消费者应该能够从同一个主题消费,但使用不同的消费群体id的整个想法。
如果仍要这样做,则需要添加自定义逻辑。首先,您应该迭代消费者组并提取该主题的现有消费者组名称,然后传递给下一个消费者。