kafka消费组

Question

一个springboot项目里
配置文件中有kafka消费组的id号要配置
spring.kafka.consumer.group-id

然后消费 kafka 数据使用监听器

@KafkaListener(topics = "TOPIC_NAME")

我在配置文件里换了一个group-id名
就消费不了了

请问springboot配置中随意取一个group-id
这个服务起来后就能新建一个消费者组
还是要先用命令在kafka上建立一个消费者组
然后再在配置文件上使用已经建好的消费者组id？

Answer 1

consumer id是存储在broker上的，用来标识一个topic下的一组消费者；只有有了消费组这个概念，才能标识你消费到了哪里、offset提交、partition分配等等。。 而且资源是需要申请的。 我实在不知道该怎么回答你了，建议翻一翻官网的文档啥的，或者网上找点资料看看

Answer 2

consumer group自己定义就可以了。如果同一个group，想重复消费，需要设置auto.offset.reset，可以从头开始消费