ほとんど似た 2 つのカフカ アプリケーションがあります。どちらも、2 つのテーブルの変更について binlog をリッスンします。私の問題は、そのうちの 1 つが正常に動作することですが、2 つ目を起動しようとすると、次の例外が発生します。

エラーが指すスキーマ ファイルの内容は次のとおりです。

動作している他のアプリケーションにはまったく同じ avro ファイルがありますが、テーブル (支払い) の名前が置き換えられています。どちらのアプリも同じサーバーから実行され、同じ Kafka クラスターに接続されています。maven プラグインを使用して、avro ファイルに基づいて Java クラスを作成します。クラス Key.class が正常に作成されます。

これらは、私のアプリケーションの 2 つの重要なクラスです。

メインクラス

ストリーム クラス

マスター/スレーブ レプリケーションについては説明しませんが、MySQL Binary-Logs を .xml でクエリするときに表示されるエントリをカスタマイズしたいだけですSHOW BINLOG EVENTS。適切なテーブルでできるように、既に と で同じ情報を見つけようとしましたがinformation_schema、見つけることができませんでした。performance_schemaSELECT

ドキュメントから利用可能なフィルターは、これを直接許可していないようです。

私が欲しいのは次のようなものです：

これを達成する方法はありますか？

mysqlbinlogユーティリティを使用した現在の回避策( MySQL Containerで実行):