如何为托管在 Kubernetes 中的多个应用程序选择 Kafka 事务 ID？

Question

我有一个经典的微服务架构。因此，有不同的应用程序。每个应用程序都可能有1..N实例。系统部署到Kubernetes.所以，我们有很多不同的PODs，可以随时启动和停止。我想实现读取-处理-写入模式，所以我需要 Kafka 事务。要配置事务，我需要transaction id为每个 Kafka 生产者设置一些。（实际上，我需要transaction-id-prefix，因为我的应用程序使用 Spring，它有这样的功能API）。在应用程序重新启动后，这些IDs必须相同。那么，如何为托管在 Kubernetes 中的多个应用程序选择 Kafka 事务 ID？

Answer 1

如果消费者启动事务（读取-处理-写入），则同一应用程序的所有实例的事务 ID 前缀必须相同（以便僵尸防护在重新平衡后正常工作）。实际使用的交易 ID 是<prefix><group>.<topic>.<partition>.

如果你有多个应用程序，它们应该有唯一的前缀（尽管如果它们从不同的主题消费，它们无论如何都是唯一的）。

对于仅限生产者的交易，前缀在每个实例中都必须是唯一的（以防止 kafka 隔离生产者）。