问答详情
源自：4-3 kafka代码案例

spring.kafka.consumer.group-id怎么指定呢

spring.kafka.consumer.group-id怎么填呢，在搭建kafka服务的时候没看到有指定这个啊？

提问者：qq_Onecallaway_1 2021-01-31 23:02

个回答

  • 蛋蛋淡淡定
    2021-02-20 09:55:10

    1. @KafkaListener(topics = {"${kafka.test.topic}"},groupId = "xiaofeng1")

    2. public void consumer(String message) {

    3. logger.info("groupId = xiaofeng1, message = " + message);

    4. }


    0