如何将工作流添加到Kafka消息中？
如何将工作流添加到Kafka消息中？
提问于 2017-09-05 06:18:40
我正在将我的java项目从兔子MQ迁移到Kafka (出于某些原因)。
然而，我面临一个困难。
在当前工作流中，我将所有消息发布到兔子mq交换，并根据消息的路由键将消息重定向到一个或多个队列。我也想在卡夫卡保留同样的功能。(我知道卡夫卡最初并不适合它，但我想找个解决办法)。
基本上，我想要这样的东西:每当主题接收到消息时，基于消息中的元信息，消息应该被重定向到其他主题集。
实现这一目标的最快方法是什么？我更喜欢python或java解决方案。
谢谢
回答 1
Stack Overflow用户
回答已采纳
发布于 2017-09-05 06:29:59
如果发布带有键的Kafka消息，它们将被定向到主题分区，这样所有类似的键都会指向同一个分区。
或者，您可以使用Kafka流读取输入主题，并根据消息提供的键将消息路由到一组输出主题。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/46048165
复制相关文章
相似问题
腾讯云开发者
