【问题标题】:What's the default Ack mode for spring cloud stream kafka?spring cloud stream kafka的默认Ack模式是什么?
【发布时间】:2021-08-25 20:14:47
【问题描述】:

目前我正在使用带有 SB2.0 的 SCS。只是想知道默认的确认模式是什么?

【问题讨论】:

    标签: spring spring-boot apache-kafka spring-cloud-stream


    【解决方案1】:

    容器在每条记录AckMode.RECORD之后提交偏移量。

    【讨论】:

      【解决方案2】:

      documentation of SCS 状态

      确认模式
      指定容器确认模式。这是基于 Spring Kafka 中定义的 AckMode 枚举。如果 ackEachRecord 属性设置为 true 并且消费者不是批处理模式,那么这将使用 RECORD 的 ack 模式,否则,使用该属性提供的 ack 模式。

      所以当ackEachRecord 设置为false(这是默认值)时,它并没有真正的帮助

      虽然documentation of spring-kafka 状态

      默认的 AckMode 是 BATCH

      所以我从中得知它正在使用BATCH ackMode。

      【讨论】:

        猜你喜欢
        • 2017-06-22
        • 2018-04-28
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        相关资源
        最近更新 更多