[Apache Kafka] sink connector 오류 수정

sink connector를 설정 후 connect를 실행할때 아래와 같이 mysql driver를 못찾아서 에러가 발생했습니다.

connect 에러

 

mysql connector 다운로드 사이트 에서 최신 mysql connector를 다운받습니다.

os를 Platform Independent를 선택 후 zip버전을 다운로드 하고 압축을 풀면 mysql-connector-j-8.2.0.jar 파일이 존재합니다.

mysql 홈페이지

해당 jar파일을 kafka폴더\lib 폴더로 옮겨줍니다. 저는 D:\tools\kafka_2.13-3.6.0\libs 경로로 옮겨줬습니다.

그리고 다시 시작하면 에러가 해결된 것을 확인할 수 있습니다.

 

 

참고자료

https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/

https://www.inflearn.com/questions/893330/no-suitable-driver-%EB%82%98%EC%98%A4%EC%8B%9C%EB%8A%94-%EB%B6%84%EB%93%A4

https://sup2is.github.io/2020/06/08/kafka-connect-example.html