【发布时间】:2021-08-25 20:14:47
【问题描述】:
目前我正在使用带有 SB2.0 的 SCS。只是想知道默认的确认模式是什么?
【问题讨论】:
标签: spring spring-boot apache-kafka spring-cloud-stream
目前我正在使用带有 SB2.0 的 SCS。只是想知道默认的确认模式是什么?
【问题讨论】:
标签: spring spring-boot apache-kafka spring-cloud-stream
容器在每条记录AckMode.RECORD之后提交偏移量。
【讨论】:
确认模式
指定容器确认模式。这是基于 Spring Kafka 中定义的 AckMode 枚举。如果 ackEachRecord 属性设置为 true 并且消费者不是批处理模式,那么这将使用 RECORD 的 ack 模式,否则,使用该属性提供的 ack 模式。
所以当ackEachRecord 设置为false(这是默认值)时,它并没有真正的帮助
虽然documentation of spring-kafka 状态
默认的 AckMode 是 BATCH
所以我从中得知它正在使用BATCH ackMode。
【讨论】: