阿帕奇駱駝 - 卡夫卡生產者：動態設置主題名稱

Question

我有一個駱駝基地應用程序（春季與XML中描述的路線）。我希望它能夠將輸入消息路由到未知數量的kafka主題（基於文件名模式和主題名稱之間的可配置匹配），因此我無法事先在xml文件中爲每個模式創建生產者。

理想的情況下，我們將能夠設定的主題中的郵件標題，如分區ID ...

有沒有人有什麼建議？

Answer 1

最後這是可能的。我指的是卡夫卡消費者的錯誤來源。在最新的版本中，它的行爲完全如我所願。

topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class); 

所以人們必須在消息中設置KafkaCOnstants.TOPIC標題以便動態選擇主題。