如何添加多个消费者组？
How can I add multiple consumer group?
我想在我的 spring 项目中添加多个 kafka 消费者组。如何添加多个消费者组？
我的听众如下，
@KafkaListener(
topics = {"#{'${test.topics}'.split(',')}"},
groupId = "${test.kafka.consumer.groupid}",
concurrency = "${test.concurrency}",
containerFactory = "ListenerContainerFactory"
)
void messageReceiver(@Payload List<String> data) {
System.out.println("Message read start:");
}
像任何其他 kafka 客户端一样，定义另一个具有唯一 groupId
的消费者（@KafkaListener，此处）
我想在我的 spring 项目中添加多个 kafka 消费者组。如何添加多个消费者组？ 我的听众如下，
@KafkaListener(
topics = {"#{'${test.topics}'.split(',')}"},
groupId = "${test.kafka.consumer.groupid}",
concurrency = "${test.concurrency}",
containerFactory = "ListenerContainerFactory"
)
void messageReceiver(@Payload List<String> data) {
System.out.println("Message read start:");
}
像任何其他 kafka 客户端一样，定义另一个具有唯一 groupId
@KafkaListener，此处）