@KafKaListener()注解

• id：指定该监听器的唯一id，Spring 容器中 MessageListenerContainer 的唯一标识符（Bean ID）

• groupid：消费者组id。消费者组是一组共享相同 Topic 的消费者的集合。

  • 当groupid没配置时但配置了id时：使用id作为groupid

  • 当groupid和id都没配置时：使用yml文件中配置的默认groupid

    • ▼
      yaml
      复制代码
      spring:
        kafka:
          consumer:
            group-id: springboot-test-listener
      

  • 优先级从高到低为groupid,id,yml文件，如果都没有就会报错

  • 其中一个消费者组可以包含多个id不同的监听器

• topics：指定要消费的 Topic 的名称，可以是字符串或字符串数组。必填参数。

• containerFactory：指定要使用的 KafkaListenerContainerFactory 实例的名称。如果没有指定，将使用默认的 KafkaListenerContainerFactory 实例。

• concurrency：指定要创建的并发消费者的数量。默认值为 1。

• autoStartup：指定容器是否在应用启动时自动启动。默认值为 true。

• errorHandler：指定在处理消息时出现异常时要使用的 ErrorHandler 实例。

• properties：指定传递给消费者工厂的 Kafka 消费者配置属性的 Map。

• partitionOffsets: 是一个 Map 类型的参数，该参数用于指定要从 Topic 的每个分区的哪个偏移量开始消费消息

参考：https://mp.weixin.qq.com/s?__biz=MzU4NDcxOTM3OQ==&mid=2247485514&idx=1&sn=546b5e6a5fcc5c0052bb63238257516b&chksm=fd94c536cae34c207bf7abd5a514aff299122d6b68e671fdbb52693cded409b6c8a2b21c1f14&cur_album_id=2829784472496734210&scene=189#wechat_redirect