Comment ajouter du flux de travail aux messages Kafka?

Question

Je migre mon projet java de Rabbit MQ vers Kafka (pour certaines raisons).

Cependant, je fais face à une difficulté. Dans le flux de travail courant, j'envoie tous les messages au lapin mq exchange, et en fonction de la clé de routage des messages, les messages sont redirigés vers une ou plusieurs files d'attente. Je veux garder la même fonctionnalité dans Kafka aussi. (Je sais que kafka ne convient pas à l'origine, mais je veux une solution de contournement).

Fondamentalement, je veux quelque chose comme ceci: chaque fois qu'un message est reçu par un sujet, basé sur la méta présente dans le message, le message devrait être redirigé vers un autre ensemble de sujets.

Quel est le moyen le plus rapide d'y parvenir? Je préférerais python ou solution java

Merci

Answer 1

Si vous publiez des messages Kafka avec les clés, ils seront dirigés vers des partitions de sujets tels que toutes les clés semblables vont à la même partition. Vous pouvez également utiliser Kafka Streams pour lire un sujet d'entrée et acheminer des messages vers un ensemble de rubriques de sortie en fonction des clés fournies avec les messages.