0

提前感谢您的帮助。

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

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

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

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

非常感谢您的帮助。

再次感谢。

4

2 回答 2

2

Kafka 对消息有效负载是不可知的，所以这应该可以正常工作。你在那里的东西看起来像一条简单的短信。

于 2015-07-05T17:40:28.863 回答
1

也许您正在寻找一种将对象序列化/反序列化到 XML 的方法。如果是这种情况，我建议您查看 Jackson https://github.com/FasterXML/jackson-dataformat-xml。

于 2015-07-05T19:38:55.193 回答