小编Nid*_*ose的帖子

在 Spring Kafka 上偏移提交,同时 setBatchListener(true) 和enable.auto.commit true

有人可以帮助理解消费者线程何时使用 spring kafka 批处理侦听器提交偏移量并将自动提交设置为 true 吗?默认情况下,消费者线程会在处理完批次中的所有消息后提交偏移量吗?我知道如果 autoCommit 为 false,提交将基于 AckModes,但想知道 autoCommit 何时为 true

  • Spring Kafka -batchListener -true
  • 启用自动提交 - true
  • MAX_POLL_RECORDS_CONFIG - 默认 (500)
  • MAX_POLL_INTERVAL_MS_CONFIG - 默认(5 分钟)

kafka-consumer-api spring-kafka

3
推荐指数
1
解决办法
1662
查看次数

标签 统计

kafka-consumer-api ×1

spring-kafka ×1