Kafka 事件路由器：过滤和基于内容的路由，如何？

数据在 Kafka 的 chat.* 主题中可用。我们可以只启动多个消费者并将 all 挂钩到这个单一的消费事件中。

但是，并非所有产品都希望处理主要主题中的完整事件。我们想根据主题中记录的内容将主题分支为多个主题。如何在 Kafka 中执行基于内容的路由？

Kafka Streams 适用于 Java 应用程序，但我们需要一个多堆栈解决方案，该解决方案可以跨公司使用多种语言？

我们正在为 Kafka 寻找一种事件路由器。 AWS 事件桥就是这样做的！但它不是卡夫卡。你如何在 Kafka 中进行这种基于内容的路由？

有什么建议吗？