H5W3
当前位置:H5W3 > 其他技术问题 > 正文

kafka消费组

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

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

@KafkaListener(topics = “TOPIC_NAME”)

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

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

回答:

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

回答:

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

本文地址:H5W3 » kafka消费组

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址