問題タブ [embedded-kafka]

すべての MySQL データベース データを Kafka トピックにプッシュする必要があるユース ケースがあります。これで、Kafka コネクタを使用してこれを実行できることがわかりましたが、コネクタを使用せずに内部ですべてがどのように機能するかを理解したいと思います。私の春のブートプロジェクトでは、すべての構成を設定し、プロデューサーレコードを作成するなど、Kafka プロデューサーファイルを既に作成しています。

誰かがこのアプローチを以前に試したことがありますか? 誰でもこれに光を当てることができますか？

spring-cloud-stream を使用してカフカ トピックから消費し、処理を行い、別のカフカ トピックに公開するスプリング ブート アプリケーションがあります。アプリケーションは正常に動作し、単体テストも (TestBinder を使用して) 作成しましたが、正常に動作しています。

現在、組み込みの Kafka を使用して統合テストを作成し、エンドツーエンドの機能をテストしようとしています。ここのサンプルをフォローしましたhttps://github.com/spring-cloud/spring-cloud-stream-samples/blob/master/testing-samples/test-embedded-kafka/src/test/java/demo/EmbeddedKafkaApplicationTests 。 Javaでテストを記述しますが、これは機能しません。出力トピックに関するメッセージを受け取ることができません。

アプリケーション.yml

TransformerBinding.java

EventProcessor.java

EventProcessorTest.java

上記のテストは、1 つのレコードが存在することを期待しているのに、出力トピックで 0 レコードを取得しているため、失敗します。