【问题标题】:AWS MSK Default enable.auto.commit settingAWS MSK 默认 enable.auto.commit 设置
【发布时间】:2021-09-13 21:02:45
【问题描述】:

AWS 的 Apache Kafka (MSK) 托管流是否默认将 enable.auto.commit 设置为 true?我没有出现在文档中,我想确保我的消费者正确地提交了偏移量。

或者 MSK 是否遵循引用 here 的 Kafka 流程,如果消费者设置 ConsumerGroup ID,则默认情况下 MSK 会自动设置 enable.auto.commit = true

【问题讨论】:

  • MSK 是托管服务器。它不会修改客户端设置
  • @OneCricketeer 啊,这是消费者设置。感谢您为我指明正确的方向。

标签: apache-kafka aws-msk


【解决方案1】:

group.idenable.auto.commit 将设置在同一位置,在消费者客户端中,并且不受服务器端控制,因此在 MSK 或任何其他 Kafka 环境中没有这样的“默认”在您的代码之外进行控制。

【讨论】:

    【解决方案2】:

    enable.auto.commit 是消费者设置,而不是集群设置。消费者负责指导 Kafka 将其提交到 __consumer_offsets 主题。

    【讨论】:

      猜你喜欢
      • 2019-09-15
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2023-01-13
      • 2023-01-03
      • 2021-07-28
      相关资源
      最近更新 更多