时间戳

首页 > 解决方案 > Apache Kafka 中的“简单消费者组”是什么？

java - Apache Kafka 中的“简单消费者组”是什么？

问题描述

我使用下面的代码来查找 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 是什么。

什么是简单消费群？

标签： javaapache-kafka

解决方案

它是kafka中consumer-group的一个实现，使用它的主要原因是比其他consumer group更好地控制分区消耗（更多的实现可用）。

有关详细答案，您可以查看此链接https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example

推荐阅读