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 は、 Google Cloud内のコンシューマー グループを表示、更新、削除するための API を提供します。

次のステップ

Apache Kafka® は、Apache Software Foundation または米国その他の諸国における関連会社の商標です。