debezium (1) 썸네일형 리스트형 [Debezium] Mysql Binlog를 이용하여 특정 시점부터 다시 메세지 전송하는 방법 debezium with kafka connect는 디비지움의 offset (혹은 체크포인트)를 카프카 토픽(`offset.storage.topic으로 설정된 값`)에 저장한다. 이를 통해 디비지움이 재시작되면 offset 토픽에서 마지막으로 저장된 체크포인트부터 다시 카프카로 프로듀싱을 하게 되는데, 이때 몇가지 이슈가 발생해서 과거 시점부터 다시 빈로그를 프로듀싱 해야할 일이 발생했다. 공식 가이드 문서에 따르면 offset 카프카 토픽에 아래와 같은 데이터를 프로듀싱하면 된다고 나와있다. 다만 offset 토픽에 프로듀싱 해야하는 값들(ts_sec, file, pos, row, server_id, event)는 어디서 가지고 와야 하는지 나와있지 않아 여러가지 방법으로 처리한 결과를 정리해보고자 한.. 이전 1 다음
