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® 是 The Apache Software Foundation 或其關聯企業在美國與/或其他國家/地區的註冊商標。