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