你需要每個主題的KafkaTemplate嗎？

Question

看起來像KakfkaTemplate可以使用泛型來配置以指示鍵和值。特定於用例的密鑰類型是什麼？例如一些標識信息，比如personId，patientId，該值會呈現某種pojo（DTO，可能不是整個JPA實體）

這導致了一個問題，我們應該根據用例配置多個KafkaTemplates ）？

Answer 1

KakfkaTemplate是通用的編碼方便。 但是，如果您的不同主題涉及不同的數據類型，那麼您應該考慮爲此目的設置一個單獨的類型安全的KakfkaTemplate。

另注：KakfkaTemplate是完全基於KafkaProducer，這需要特別ProducerProperties包括key/value串行。

因此，對於不同的數據類型，您需要單獨KafkaProducer s，因此KakfkaTemplate。即使他們看着同一個卡夫卡經紀人。