如何将工作流添加到Kafka消息中？

Question

我正在将我的java项目从Rabbit MQ迁移到Kafka（出于某些原因）。在

然而，我面临一个困难。在

在当前工作流中，我将所有消息发布到rabbit mq exchange，并根据消息的路由键将消息重定向到一个或多个队列。 我想在Kafka中保留相同的功能。（我知道卡夫卡最初并不适合，但我需要一个变通办法）。在

基本上，我想要这样的东西：当一个主题接收到一条消息时，基于消息中存在的元，消息应该被重定向到其他主题集。在

实现这一目标的最快方法是什么？我更喜欢python或java解决方案

谢谢

Answer 1

如果您发布带有键的Kafka消息，它们将被定向到主题分区，这样所有相似的键都将转到同一个分区。在

或者，您可以使用Kafka流来读取输入主题，并根据消息提供的键将消息路由到一组输出主题。在