如何將工作流程添加到Kafka消息？

我正在將我的Java項目從Rabbit MQ遷移到Kafka（出於某些原因）。如何將工作流程添加到Kafka消息？

但是，我面臨着一個難題。

在當前工作流程中，我將所有消息發佈到rabbit mq exchange，並根據消息的路由密鑰將消息重定向到一個或多個隊列。我想在卡夫卡也保留相同的功能。（我知道kafka本來不適合它，但我想要一個解決方法）。

基本上，我想要這樣的東西：每當一個主題收到一條消息時，根據消息中存在的元，消息應該被重定向到其他主題集。

實現此目的的最快方法是什麼？我寧願Python或Java解決方案

感謝

2017-09-05 praddy

[Streaming messages to multiple topics]可能重複（https://stackoverflow.com/questions/42388525/streaming-messages-to-multiple-topics） –

如果您發佈的鑰匙，他們將被引導到主題分區，使得所有類似鑰匙去同一個分區卡夫卡的消息。

或者，您可以使用Kafka Streams讀取輸入主題，並根據消息提供的密鑰將消息路由到一組輸出主題。

2017-09-05 06:29:59

有沒有關於此的任何教程或博客？ – praddy

是否可以使用1個主題作爲交換。每當用某個鍵值對在主題上接收到消息時，將其重定向到一組特定主題？ – praddy

看看這個：https：//stackoverflow.com/questions/42388525/streaming-messages-to-multiple-topics –

回答