我有 spring-boot-1.5.13
使用的应用程序 spring-kafka
. 当应用程序启动并正在生成( KafkaTemplate.send()
)/消耗( @KafkaMessageListener
),它不列为活动消费者。它显示了所有的 console-consumer
活动/非活动但从不 consumer_group
应用程序正在使用的。
/opt/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --new-consumer --list
console-consumer-80187
console-consumer-95926
console-consumer-55164
console-consumer-45212
Spring ConsumerConfig
指定 group.id
, auto.commit.enable=true
暂无答案!
目前还没有任何答案,快来回答吧!