是的,Kafka的消费者组ID(group ID)可以手动设置。在创建消费者时,可以通过设置group.id
属性来指定消费者所属的消费者组ID。如果不指定group.id
,则Kafka会为该消费者生成一个默认的消费者组ID。
以下是一个使用Java客户端库创建Kafka消费者的示例,其中手动设置了消费者组ID:
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-consumer-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("my-topic"));
在这个示例中,我们将消费者组ID设置为my-consumer-group
。这将使得该消费者加入名为my-consumer-group
的消费者组,并从my-topic
主题中消费消息。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:kafka的groupid能手动指定吗