【发布时间】:2018-08-18 08:30:32
【问题描述】:
我试图使用 kafka 流库只使用一次 kafka 的功能。我只将proessing.guarantee 配置为exact_once。除此之外,还需要将事务状态存储在内部主题 (__transaction_state) 中。
我的问题是,如何自定义主题名称?如果 kafka 集群被多个消费者共享,每个客户是否需要不同的主题来进行事务管理?
谢谢 穆尔蒂
【问题讨论】:
我试图使用 kafka 流库只使用一次 kafka 的功能。我只将proessing.guarantee 配置为exact_once。除此之外,还需要将事务状态存储在内部主题 (__transaction_state) 中。
我的问题是,如何自定义主题名称?如果 kafka 集群被多个消费者共享,每个客户是否需要不同的主题来进行事务管理?
谢谢 穆尔蒂
【问题讨论】:
您无需担心主题__transaction_state -- 它是一个内部主题,会自动为您创建 -- 您无需手动创建它,它始终具有此名称(不是可以自定义名称)。它将用于所有使用事务的生产者。
【讨论】: