我想使用kafka作为我的消息中间件的核心。
这意味着，除了kafka提供的消息传输之外，我还需要在生产者发送的有效负载和消费者接收的有效负载之间进行有效负载转换/充实。实际上，在很多用例中，生产者使用的格式并不是最适合消费者的格式。
一个明显的例子是，让大型机应用程序生成cobol copybooks作为生产者，让节点应用程序优化为基于json的格式作为消费者！或者更常见的情况是，两个应用程序使用xml语法，但模式不同。
在（传统的）面向消息的中间件中，这种负载转换通常由xslt执行，xslt是一种专用的、性能良好的语言，用于将xml文档转换为其他xml文档。saxon是市场上领先的xslt处理器之一。
现在，我正在寻找如何把撒克逊和Kafka结合起来的建议/例子。。。任何提示/意见/指示，甚至问题都将不胜感激！
非常感谢！