在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")
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:kafka中group组指定的方法是什么