java - Kafka 消息 - Java 中的生产者和消费者客户端

Question

感谢您提前提供的帮助。

我想在 Kafka 代理中以以下格式推送和拉取消息。

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

Java 中的生产者客户端应该能够以这种格式推送，消费者客户端应该能够读取和解析该消息。我怎样才能做到这一点？ Kafka Java API 中有没有特定的方法可以做到这一点？

我已经编写了生产者和消费者 Java 客户端来推送和拉取简单的文本消息。

非常感谢您的帮助。

再次感谢。

Answer 1

Kafka 对于消息负载是不可知的，所以这应该可以正常工作。您看到的内容看起来像是一条简单的短信。