提前谢谢你的帮助。
我想在kafka代理中按以下格式推拉消息。

<header>
  <version></version>
  <id></id>
</header>
  <detail>
     <firstname></firstname>
     <lastname></lastname>
     <salary></salary>
  </detail>

java中的生产者客户机应该能够以这种格式推送消息，消费者客户机应该能够读取和解析消息。我该怎么做？在kafkajavaapi中有什么特殊的方法可以做到这一点吗？
我已经编写了生产者和消费者java客户端来推拉简单的文本消息。
非常感谢你的帮助。
再次感谢。