分割主題數據

我想一個主題分成serveral的主題，基於數據的特定字段。是否有可能在流媒體中進行這樣的操作？分割主題數據

或者我應該寫一個典型的消費者和生產者？

例：

輸入主題：數據與屬性A（值AAA，BBB，CCC），B，C，d和E

輸出主題：3個主題使用名稱AAA，BBB和CCC具有相同的數據作爲輸入主題

此致盧卡斯

2017-09-22 Lukas

[將一個Kafka輸入流動態連接到多個輸出流]的可能重複（https://stackoverflow.com/questions/41796207/dynamically-connecting-a-kafka-input-stream-to-multiple-output-streams ） –

您可以使用您的branch() method流中分裂成幾個流。比每個流可以寫在自己的話題。

2017-09-22 10:51:40

我要動態地分成幾個流，所以它不可能使用分支的方法，因爲我應該知道之前分割標準。我必須將傳入的流分成幾百個其他流。我想我只能用消費者和生產者來做這件事。 – Lukas

喜盧卡斯，據我所知流，你可以存檔這樣的行爲只能用自己的消費者，生產者對。另外，看看流的低LVL API，可在水槽處理器可以根據需要定義的功能。 –

回答