在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")