kafka-connect-jdbc 날짜 시간

Question

kafka-connect-jdbc를 사용하여 기존 데이터베이스 (mysql)에서 kafka로 데이터를 가져 오려고합니다. 기본 예제를 설정하고 작동시킬 수있었습니다.

은 java.sql.SQLException : 값 문제의

하나는 그 중 우리가 예외가 사촌 타임 스탬프 있어야하는데 열 중 하나는, 모든 행에 대해 잘못된 값을 가지고 있다는 것입니다 '0000-00-00'는을 java.sql.Timestamp로 표현 될 수없는

나는 쉽게 그 열을 제외 할 수 있습니다 데이터는 선택을 작성하여 카프카 - 연결 - JDBC에서 사용자 지정 쿼리 옵션을 사용하여 가져온 해당 열을 제외한 쿼리. 오프셋 관리 등의 측면에서 그 의미를 이해하고 싶었습니다. 문서 당 문제 중 하나는 커넥터 당 하나의 주제로만 제한된다는 것입니다. 염두에 두어야 할 것은 무엇입니까?

Answer 1

연결 문자열에서 mysql zeroDateTimeBehavior 옵션을 사용하여이 특정 문제 (날짜)를 해결했습니다. 이와 같은 것을 추가하는 것 & zeroDateTimeBehavior = round는 날짜가 더 이상 0000-00-00이 아닌 곳에 나를 위해 그것을 고쳤습니다. 여기에 더 많은 정보 : MySQL의 문서 드라이버가 가 (잘못된 날짜를 표현하기 위해 MySQL이 사용하는) 제로의 전체 구성되어 DATETIME 값을 만나면 어떻게해야합니까

zeroDateTimeBehavior 

에서

? 유효한 값은 "exception", "round"및 "convertToNull"입니다.

기본값 : 예외

버전 이후로는 : 3.1.4

나는 아직도하지만 사용자 지정 쿼리를 사용하여의 의미를 알고 싶습니다.