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

【问题标题】：Kafka Messages - Producer & Consumer Client in JavaKafka 消息 - Java 中的生产者和消费者客户端
【发布时间】：2015-09-18 22:13:50
【问题描述】：

提前感谢您的帮助。

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

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

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

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

非常感谢您的帮助。

再次感谢。

【问题讨论】：

标签： java apache-kafka kafka-consumer-api

【解决方案1】：

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

【讨论】：

【解决方案2】：

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

【讨论】：