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 に答える