我正在将java项目从rabbitmq迁移到kafka（出于某些原因）。然而，我面临一个困难。在当前工作流中，我将所有消息发布到rabbitmqexchange，并根据消息的路由密钥，将消息重定向到一个或多个队列。我想保留Kafka同样的功能我知道Kafka最初并不适合它，但我想要一个解决办法）。基本上，我想要这样的东西：每当一个主题收到一条消息时，基于消息中存在的元，消息应该被重定向到其他一组主题。最快的方法是什么？我更喜欢python或java解决方案谢谢
k97glaaz1#
如果您发布带有密钥的kafka消息，它们将被定向到主题分区，这样所有相似的密钥都将转到同一分区。或者，您可以使用kafka流来读取输入主题，并根据消息提供的键将消息路由到一组输出主题。
1条答案
按热度按时间k97glaaz1#
如果您发布带有密钥的kafka消息，它们将被定向到主题分区，这样所有相似的密钥都将转到同一分区。
或者，您可以使用kafka流来读取输入主题，并根据消息提供的键将消息路由到一组输出主题。