I would like to enrich some streaming data, with one service per enrichment, possibly each service written in a different language and managed/deployed separately.
Each service would consume some Kafka topic, enrich the message, and publish it in some Kafka topic.
In the end, I would have a topic of fully enriched messages.
Ideally, some of the steps would be done concurrently, but this is not a requirement.
What are frameworks, protocols, or patterns matching this kind of use cases ? To me it looks like regular async micro services, but with high risk of coupling between the services.