Managed Service for Apache Kafka 中的消费者群组概览

消费者群组定义了一组并行读取主题中记录的消费者。系统会为群组中的每个消费者分配主题分区的一个子集，以便从中读取数据。

如需创建消费者群组或将消费者添加到现有群组，请在消费者中设置 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 或其关联公司在美国和/或其他国家/地区的注册商标。