Google Cloud Managed Service for Apache Kafka 消费者群组概览

消费者群组是一组协同从各种主题中消费数据的消费者。一个消费组中的所有消费者都具有相同的 group.id。 无需明确创建消费者群组，默认情况下，系统会随机选择一个消费者 group.id。如需使用特定的 group.id，您只需启动新的消费者应用，并在消费者属性文件中将 group-id 设置为消费者组 ID。如果指定的 group-id 不存在，Kafka 会创建一个新的消费群组。

例如，使用 Kafka 控制台使用方时：

 kafka-console-consumer.sh --topic TOPIC --bootstrap-server BOOTSTRAP  --group GROUP

替换以下内容：

  • TOPIC：主题名称。
  • BOOTSTRAP：引导服务器。
  • GROUP：消费群组 ID。

您还可以使用客户端属性文件设置其他配置选项，例如偏移管理设置。如需了解详情，请参阅 Apache Kafka 文档中的使用方配置。

Managed Service for Apache Kafka 提供了一些 API，用于查看、更新和删除 Google Cloud中的消费者群组。

后续步骤

Apache Kafka® 是 Apache Software Foundation 或其关联公司在美国和/或其他国家/地区的注册商标。