【问题标题】:Kafka streams - exactly once configurationKafka 流 - 仅一次配置
【发布时间】:2018-08-18 08:30:32
【问题描述】:

我试图使用 kafka 流库只使用一次 kafka 的功能。我只将proessing.guarantee 配置为exact_once。除此之外,还需要将事务状态存储在内部主题 (__transaction_state) 中。

我的问题是,如何自定义主题名称?如果 kafka 集群被多个消费者共享,每个客户是否需要不同的主题来进行事务管理?

谢谢 穆尔蒂

【问题讨论】:

    标签: apache-kafka-streams


    【解决方案1】:

    您无需担心主题__transaction_state -- 它是一个内部主题,会自动为您创建 -- 您无需手动创建它,它始终具有此名称(不是可以自定义名称)。它将用于所有使用事务的生产者。

    【讨论】:

      猜你喜欢
      • 2018-09-27
      • 1970-01-01
      • 2022-01-21
      • 2018-10-28
      • 1970-01-01
      • 1970-01-01
      • 2021-09-28
      • 1970-01-01
      • 2017-04-18
      相关资源
      最近更新 更多