是的,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
主题中消费消息。