2.4.3.2. Kafka Connect プロセスのクラッシュ

Kafka Connect がクラッシュすると、プロセスが停止し、直近で処理されたオフセットが記録されずに Debezium MySQL コネクタータスクが終了します。Distributed モードでは、Kafka Connect は他のプロセスでコネクタータスクを再起動します。ただし、MySQL コネクターは、前のプロセスで記録された最後のオフセットから再開します。つまり、代替のタスクにより、クラッシュ前に処理される同じイベントの一部が生成される可能性があり、重複イベントが作成されます。