chanc0632

하단과 같이 하면 될 듯 합니다.MySQL의 datetime에는 타임존이 없으나, mysql-binlog-connector-java에서는 Datetime 클래스 기반으로 날짜 처리를 하다보니. 자연스럽게 DBMS와 JVM 타임존 영향을 받게 됩니다. <pre><code>transforms=convertTimezone
transforms.convertTimezone.type=io.debezium.transforms.TimezoneConverter
transforms.convertTimezone.converted.timezone=Asia/Seoul</code></pre>추가적으로 확인은 필요하지만, 위 적용 이후 MySQL의 time과 같은 타입도 정상적으로 의도한 결과대로 나오는지 체크도 해봐야합니다. Connector레벨에서 타임존 없는 데이터는 원천 데이터 그대로 전달해주면 좋을텐데.. (String타입일지라도. ^^)

chanc0632

Posts