問題タブ [debezium]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Debezium は mysql の組み込みバージョンの CDC を提供していません
以下の依存関係を使用していますが、
以下は私のJavaメソッドです。
私のSQL構成、.
このコードを実行すると、履歴ログのオフセットが取得され、mysql.log ファイルにもオフセットが追加されます。ただし、テーブルに対して更新ステートメントを実行しているときに、ログが表示されません。つまり、handleEvent メソッドが呼び出されません。コードまたは構成の何が問題なのか誰にも教えてもらえますか?
以下は、Java コードを実行した後のログです。
log4j:WARN ロガー (org.apache.kafka.connect.json.JsonConverterConfig) のアペンダーが見つかりませんでした。log4j:WARN log4j システムを適切に初期化してください。
log4j:WARN http://logging.apache.org/log4j/1.2/faq.html#noconfigを参照詳細については。2018 年 11 月 28 日 1:29:47 PM com.debezium.gcp.SampleMysqlEmbededDebezium handleEvent 情報: レコードを取得しました:SourceRecord{sourcePartition={server=my-app-connector}、sourceOffset={file=mysql-bin.000002、pos= 980, gtids=31b708c7-ee22-11e8-b8a3-080027fbf50e:1-17, スナップショット=true}} ConnectRecord{topic='my-app-connector', kafkaPartition=0, key=Struct{databaseName=}, value=Struct {source=Struct{version=0.8.3.Final,name=my-app-connector,server_id=0,ts_sec=0,file=mysql-bin.000002,pos=980,row=0,snapshot=true}, databaseName=,ddl=SET character_set_server=latin1, collation_server=latin1_swedish_ci;}, timestamp=null, headers=ConnectHeaders(headers=)} 2018 年 11 月 28 日 1:29:47 PM com.github.shyiko.mysql.binlog.BinaryLogClient 接続情報: 31b708c7-ee22-11e8-b8a3-080027fbf50e:1-17 で localhost:3306 に接続されました (sid:6326、cid:21)
kubernetes - minikube に debezium をデプロイできません
私は kubernetes を初めて使用します。kafka を debezium および mysql と統合しようとしています。minikube に kafka と mysql を正常に展開し、debezium yml を minikube に展開すると、ハングしてまったく応答しなくなり、minikube を再起動します。すべてのポッドを実行した後、minikube が再びハングしました。以下は私のコードです：
飼育係サービス
飼育係の配備:
カフカサービス:
カフカ展開:
MySql 永続ボリューム:
mysql の展開:
Debezium の展開:
debezium を展開すると、問題が発生し、次のような minikube 応答が発生します
OS：
Centos minikube バージョン：v0.30.0