如何在Spring Kafka中通过application属性配置factory.setAckDiscarded(true)

配置对应关系 #

两个代码配置和配置文件属性的对应关系如下：

• factory.setBatchListener(true)：Spring Kafka 2.2及以上版本对应配置spring.kafka.listener.type=batch，更低版本可使用已废弃的配置项spring.kafka.listener.batch-listener=true
• factory.setAckDiscarded(true)：对应配置spring.kafka.listener.ack-discarded=true，仅Spring Kafka 2.2及以上版本支持该配置项

完整配置示例 #

application.properties写法 #

# 开启批量监听器
spring.kafka.listener.type=batch
# 被丢弃的消息自动提交ack
spring.kafka.listener.ack-discarded=true

application.yml写法 #

spring:
  kafka:
    listener:
      type: batch # 开启批量监听器
      ack-discarded: true # 被丢弃的消息自动提交ack

注意事项 #

如果你的Spring Kafka版本低于2.2，不支持ack-discarded配置项，仍然需要保留代码中的factory.setAckDiscarded(true)写法。配置生效后无需再在代码中手动调用对应set方法。

内容的提问来源于stack exchange，提问作者MR_K