Kafka ConnectのDLQに入ったメッセージをどうリカバリするか
#kafka
#kafka-connect
#2021-advent-calendar
Kafka Connectには
DLQ
の機能があるが、DLQに入ったメッセージをリカバリするための機能がない。そのため、再度同様のメッセージを生成しなおすか、assign()/seek()等で連携に失敗したメッセージのオフセットからデータを読み直すかといった対応が別途必要になる。