1.4.3.2. Kafka Connect プロセスのクラッシュ
Kafka Connect がクラッシュすると、プロセスが停止し、最後に処理されたオフセットが記録されずに Debezium MySQL コネクタータスクが終了します。分散モードでは、Kafka Connect は他のプロセスでコネクタータスクを再起動します。ただし、MySQL コネクターは以前のプロセスで記録された最後のオフセットから再開します。つまり、代替タスクはクラッシュ前に処理された同じイベントの一部を生成し、重複したイベントを作成することを意味します。
ヒント
各変更イベントメッセージには、以下に関するソース固有の情報が含まれます。
- イベント元
- MySQL サーバーのイベント時間
- binlog のファイル名および位置
- GTID (使用されている場合)