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