当前位置: 首页 > 知识库问答 >
问题:

如何向Kafka消息添加工作流?

严昀
2023-03-14

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

在当前的工作流中,我将所有消息发布到rabbit mq exchange中,并根据消息的路由密钥将消息重定向到一个或多个队列中。我也想保留Kafka同样的功能。(我知道Kafka本来就不适合,但我想要一个变通办法)。

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

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

共有1个答案

张腾
2023-03-14

如果您发布带有键的Kafka消息,它们将被定向到主题分区,以便所有相似的键都指向同一个分区。

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

 类似资料:
  • 我是springboot kafka的新手,我在这篇文章后面创建了一个例子。 https://www.codenotfound.com/spring-kafka-boot-example.html 我发现您可以将kafka元数据设置为标题,但这不符合我的目的。 我能做到这一点吗?如果可能的话,我很感激你能分享一个例子。

  • 我是新手颤动,我使用Firebase消息发送通知到设备,我们使用Web API发送请求到Firebase发送通知和Firebase发送通知到Android。我想在通知标题和身体显示两个按钮(接受和拒绝)像瓦特应用程序通知标记为已读选项我想要这样的东西。 我添加的Android清单文件: 颤振码 Web api服务代码

  • 创建工作流后,它被保存为XML文件,为了检查转换后的工作流的外观,它被上传到bpmn.io(目前包括一个消息对象,如果XML文件在bpmn.io上传,该对象将不显示):

  • 我使用log4j2,我想给我所有的消息添加一个前缀。这个前缀被传递给构造函数参数,它取决于类的实例。所以我们在对象级别(不是类或线程)。 例如,我有一个实例化的类,就像一样,所以当我在这个类上使用时,就在消息之前编写。对于,将显示。 谢谢你的帮忙