Springコンフルエントスキーマデシリアライズの例

Question

spring-kafka 2.0.0.Releaseを使用していて、コンフルエントなスキーマレジストリを使用してメッセージをデシリアライズするソースを作成した人はいますか？

私が解決しようとしている問題は、MongoDBのイベントを発生させるkafka接続プラットフォームにDebezium CDCコネクタがあることです。私はそれらのイベントを変換して再ストリームを傍受する必要があります。イベントを理解するために、ペイロードを逆シリアル化する必要があります。私は現在このステップで立ち往生しています。

Answer 1

Sastry

この問題はwhile backに対処しているように見えるので、私は次のテストコードとあなたはカフカのスキーマレジストリを設定することができ、特定のpart in itを指摘したいと思います。 明らかかどうかを確認してください。