我有一個經典的微服務架構。因此,有不同的應用程序。每個應用程序都可能有1..N實例。系統部署到Kubernetes.所以,我們有很多不同的PODs,可以隨時啟動和停止。我想實現讀取-處理-寫入模式,所以我需要 Kafka 事務。要配置事務,我需要transaction id為每個 Kafka 生產者設置一些。(實際上,我需要transaction-id-prefix,因為我的應用程序使用 Spring,它有這樣的功能API)。在應用程序重新啟動后,這些IDs必須相同。那么,如何為托管在 Kubernetes 中的多個應用程序選擇 Kafka 事務 ID?
如何為托管在 Kubernetes 中的多個應用程序選擇 Kafka 事務 ID?
慕蓋茨4494581
2023-04-19 15:47:38