kafka connect 0.9x의 가장 큰 이슈는 

mysql 드라이버를 com.mysql.cj.jdbc.driver로 하드 코딩되어 있다는 점이다. 

(잘 사용할려면 시간이 좀 필요하다)

 

따라서 하위 버전(5.x) mysql 드라이버를 사용하려하면 java.lang.NoClassDefFoundError: com/mysql/cj/jdbc/Driver 예외가 발생한다.

Sink Connector에 mysql-connector 8 대신 mysql-connector 5로 바꿔서 사용하고 싶지만 실제로 사용할 수 없다.

Sink Connector 테스트 종료. (현재 버전까지는 사용할 수 없는 형태임)
https://github.com/confluentinc/kafka-connect-jdbc/issues/573

Posted by '김용환'
,