我用下面的代码找到了Kafka的消费群体。
ListConsumerGroupsResult listConsumerGroups = admin.listConsumerGroups();
listConsumerGroups.all().get().forEach(v -> {
logger.info("{}", v);
});
结果如下。
[main] INFO KafkaAdminClient - (groupId='test-consumer-group', isSimpleConsumerGroup=false)
[main] INFO KafkaAdminClient - (groupId='wordcount-example', isSimpleConsumerGroup=false)
我想知道issimpleconsumergroup是什么。
什么是简单消费群体?
1条答案
按热度按时间goucqfw61#
它是kafka中consumer group的一个实现,使用它的主要原因是它比其他consumer group对分区消耗的控制更大(可用的实现更多)。
详细的答案,你可以看看这个链接https://cwiki.apache.org/confluence/display/kafka/0.8.0+simpleconsumer+example