使用多個主題名稱與KafkaListener註釋

Question

也存在類似的問題，下面問：

---

Can a single Spring's KafkaConsumer listener listens to multiple topic?

所以，我現在明白了，我可以提供一個字符串數組到KafkaListener註釋的主題參數，但我想知道以下內容：

1. 如何從屬性文件中獲取主題名稱作爲字符串數組？
2. 這個來自多個主題的閱讀如何影響偏移量？客戶（春季卡夫卡）會保持每個主題的偏移嗎？

Answer 1

如果你的財產是my.topics（以逗號分隔）...

@KafkaListener(id = "foo", topics = "#{'${my.topics}'.split(',')}") 

是，偏移量爲所有訂閱的主題/分區管理。