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

来源:4-3 kafka代码案例

qq_Onecallaway_1

2021-01-31 23:02

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

写回答 关注

1回答

  • 蛋蛋淡淡定
    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. }


Kafka流处理平台

作为模块解耦和大数据处理黏合剂的不二之选Kafka,你值得拥有!

33838 学习 · 49 问题

查看课程

相似问题