qq_Onecallaway_1
2021-01-31 23:02
spring.kafka.consumer.group-id怎么填呢,在搭建kafka服务的时候没看到有指定这个啊?
@KafkaListener(topics = {"${kafka.test.topic}"},groupId = "xiaofeng1")
public void consumer(String message) {
logger.info("groupId = xiaofeng1, message = " + message);
}
Kafka流处理平台
33838 学习 · 49 问题
相似问题