相关疑难解决方法(0)

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

我有一个经典的微服务架构。所以,有不同的应用。每个应用程序可能有1..N实例。系统部署到Kubernetes.所以,我们有很多不同PODs,可以随时启动和停止。

我想实现读取-处理-写入模式,所以我需要 Kafka 事务。

要配置事务,我需要transaction id为每个 Kafka 生产者设置一些事务。(实际上,我需要transaction-id-prefix,因为我在我的应用程序中使用Spring,并且它有这样的API)。应用程序重新启动后,这些IDs必须相同。

那么,如何为 Kubernetes 中托管的多个应用程序选择 Kafka 事务 ID?

java apache-kafka kubernetes kafka-producer-api spring-kafka

4
推荐指数
1
解决办法
6048
查看次数