인프런 커뮤니티 질문&답변

https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.33/mysql-connector-j-8.0.33.jar

제 경우 mariadb 커넥터 대신 mysql 커넥터 사용해서 해결했습니다.

(... confluentXXX/share/java/kafka 폴더에 위치)

정말.. 하루종일 아래 예외로 애먹었네여..

Error while starting connector ...

No suitable driver found for jdbc:mysql://localhost:3307/mydb

mariadb 버전별 커넥터를 5개정도 해봐도 안되어서

자포자기한 채로 mysql 커넥터를 사용하니 되었습니다 ㅠㅠ

자세한 버전 정보입니다. (윈도우)

kafka : 2.13-3.4.0

kafka-connect-jdbc : 10.7.2

confluent : 7.4.0

mariaDB : 10.11

java : 17 

설정 정보입니다.

confluent/etc/kafka/connect-distributed.properties

89번 행 근처
plugin.path=\C:\\Work\\confluentinc-kafka-connect-jdbc-10.7.2\\lib

confluent/bin/windows/kafka-run-class.bat

97번 행 근처
rem classpath addition for LSB style path
if exist "%BASE_DIR%\share\java\kafka\*" (
	call :concat "%BASE_DIR%\share\java\kafka\*"
)

(...)

122번 행 근처
rem Log4j settings
IF ["%KAFKA_LOG4J_OPTS%"] EQU [""] (
	if exist %~dp0../../etc/kafka/tools-log4j.properties (
		set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%~dp0../../etc/kafka/tools-log4j.properties
	) else (
		set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%BASE_DIR%/etc/kafka/tools-log4j.properties
	)
) ELSE (
  rem create logs directory
  IF not exist "%LOG_DIR%" (
      mkdir "%LOG_DIR%"
  )
  set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%~dp0../../etc/kafka/tools-log4j.properties
)

confluent/bin/windows/connect-distributed.bat

28번 행 근처
rem Log4j settings
IF ["%KAFKA_LOG4J_OPTS%"] EQU [""] (
	set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%BASE_DIR%/etc/kafka/connect-log4j.properties -Dlog4j.config.dir=%BASE_DIR%/etc/kafka
)

POST Request

{
  "name":"my-source-connect",
  "config":{
    "connector.class" : "io.confluent.connect.jdbc.JdbcSourceConnector",  
    "connection.url":"jdbc:mysql://localhost:3307/mydb",
    "connection.user":"root",
    "connection.password":"1234",
    "mode":"incrementing",
    "incrementing.column.name":"id",
    "table.whitelist":"users",
    "topic.prefix":"my_topic_",
    "tasks.max":"1"
  }
}