消费组定义了一组并行读取主题中记录的消费者。系统会为群组中的每个使用方分配主题分区的一个子集,以供其从中读取数据。
如需创建使用方群组或将使用方添加到现有群组,请在相应使用方中设置 group.id 配置。例如,在使用 Kafka 命令行工具时,您可以按如下方式指定消费者群组:
kafka-console-consumer.sh \
--topic TOPIC \
--bootstrap-server BOOTSTRAP \
--group GROUP \
--consumer.config client.properties
替换以下内容:
TOPIC:主题名称。BOOTSTRAP:引导服务器。GROUP:消费群组 ID。
在 Managed Service for Apache Kafka 中,您可以使用 Google Cloud 控制台、Google Cloud CLI、客户端库或 Kafka 命令行工具来管理消费者群组。
接下来怎么做?
Apache Kafka® 是 Apache Software Foundation 或其关联公司在美国和/或其他国家/地区的注册商标。