Kafka connector

Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)

Kafka Source Connect 사용

작성

951

window 사용 중이고, 서버는 전부 열려있습니다만, POSTMAN에서 JSON 형식으로

{

"name" : "my-source-connect",

"config" : {

"connector.class" : "io.confluent.connect.jdbc.JdbcSourceConnector",

"connection.url":"jdbc:mysql://localhost:3306/mydb",

"connection.user":"root",

"connection.password":"test1357",

"mode": "incrementing",

"incrementing.column.name" : "id",

"table.whitelist":"users",

"topic.prefix" : "my_topic_",

"tasks.max" : "1"

}

를 보냈을 때 뜨는 오류가 "error_code": 500, "message": "Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='3.6.0', encodedVersion=3.6.0, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector, name='org.apache.kafka.connect.file.FileStreamSourceConnector', version='3.6.0', encodedVersion=3.6.0, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorCheckpointConnector, name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector', version='3.6.0', encodedVersion=3.6.0, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='3.6.0', encodedVersion=3.6.0, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector, name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='3.6.0', encodedVersion=3.6.0, type=source, typeName='source', location='classpath'}" 입니다. 어떤오류인지 잘 모르겠네요

spring-boot jpa 아키텍처 spring-cloud kafka msa

답변 2

이우진

이미 해결하셨을거라고 생각하지만 제가 해결한 방식을 공유드리겠습니다!

저는 윈도우 환경에서 plugin path 를 지정해 주었습니다.

기존의 방식으로는

plugin.path=D:\kafka_2.13-3.7.0\confluentinc-kafka-connect-jdbc-10.7.6\lib

변경된 방식으로는

plugin.path=D:\\kafka_2.13-3.7.0\\confluentinc-kafka-connect-jdbc-10.7.6\\lib

, . \ 와 같은 문자를 인식 시켜 주기위해서는 백슬래시 하나를 더 추가시켜줘야 합니다.

그래서 \가 아닌 \\를 통해 경로 설정을 해줘야 합니다.

키워드로는 이스케이프시퀸스라고 검색하시면 됩니다.

-5

인프런 AI 인턴

안녕하세요 ᄒᄒ 님, 인프런 AI 인턴이에요.

오류 메시지를 보면 “io.confluent.connect.jdbc.JdbcSourceConnector”를 구현하는 클래스를 찾을 수 없다는 것 같습니다. 이 오류는 Kafka Connect 플러그인이 설치되지 않았거나, 올바르게 설정되지 않았을 때 발생할 수 있습니다.

먼저, Kafka Connect 플러그인이 올바르게 설치되었는지 확인해보세요. 다음으로, Kafka Connect 플러그인 설정 파일 (예: “connect-standalone.properties”)에서 클래스 경로를 정확하게 지정했는지 확인해야 합니다.

만약 플러그인이 올바르게 설치되었고 설정도 정확하다면, 클래스 이름을 다시 확인해 보세요. “io.confluent.connect.jdbc.JdbcSourceConnector”가 올바른 클래스 이름인지 다시 한 번 확인해 주세요.

위의 단계를 따라도 문제가 해결되지 않는다면, 추가적인 정보가 필요할 수 있으므로 Kafka Connect 플러그인과 관련된 공식 문서나 커뮤니티를 참고하시는 것을 권장드립니다. 감사합니다!

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

Kafka connector