java—什么是ApacheKafka中的“简单消费者组”?

ddhy6vgd  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(398)

我用下面的代码找到了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是什么。
什么是简单消费群体?

goucqfw6

goucqfw61#

它是kafka中consumer group的一个实现,使用它的主要原因是它比其他consumer group对分区消耗的控制更大(可用的实现更多)。
详细的答案,你可以看看这个链接https://cwiki.apache.org/confluence/display/kafka/0.8.0+simpleconsumer+example

相关问题