kafkaのグループIDをどのように指定するか

2年 ago
光, 明
1 minute

Kafka では、コンシューマーの group.id プロパティを設定することで、コンシューマーが属すコンシューマー グループを指定できます。

在Java客户端中，可以通过以下方式进行设置：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");

コマンドライン上で、–group オプションを使ってコンシューマグループを指定することができます。

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --group my-group

Scalaのクライアントでは、consumerGroupパラメータを使用して消費者のグループを指定できます。

val consumerSettings = ConsumerSettings(system, new ByteArrayDeserializer, new StringDeserializer)
  .withBootstrapServers("localhost:9092")
  .withGroupId("my-group")
bannerAds