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