Kafka Consumerからメッセージを消費した後、ペイロードをJSONに変換できません

Question

kafkaからのメッセージを消費するためにkafkaコンシューマを使用しています。私はメッセージをJSONまたはjavaに変換するのに疲れたときにメッセージを消費することができます。それは変身していません。実際に伝えられたメッセージはjsonです。メッセージの種類が文字列であることがわかりました。あなたは私たちが

Answer 1

がトランス

、その後

オブジェクトJSON変圧器へのObjectに

のByteArrayを使用してみてくださいデータを変換する方法を教えてください可能性が代わり

あなたがすることができますまた、 "変換メッセージ"を必要な入力と出力で使用してくださいペイロード。

特定の変換が必要な場合は、使用しているフローを親切に指定してください。