溫馨提示×

kafka的group組如何指定

小億
254
2023-11-10 19:52:57

在Kafka中，可以通過設(shè)置消費(fèi)者的group.id屬性來指定消費(fèi)者屬于哪一個(gè)消費(fèi)者組。

在Java客戶端中，可以通過以下方式進(jìn)行設(shè)置：

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

在命令行中，可以使用--group參數(shù)來指定消費(fèi)者組：

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

在Scala客戶端中，可以使用consumerGroup參數(shù)來指定消費(fèi)者組：

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

0 踩