Kafka connector

Question

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'}" 입니다. 어떤오류인지 잘 모르겠네요

이우진 · Answer

이미 해결하셨을거라고 생각하지만 제가 해결한 방식을 공유드리겠습니다! 저는 윈도우 환경에서 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 , . \ 와 같은 문자를 인식 시켜 주기위해서는 백슬래시 하나를 더 추가시켜줘야 합니다. 그래서 \가 아닌 \를 통해 경로 설정을 해줘야 합니다. 키워드로는 이스케이프시퀸스라고 검색하시면 됩니다.

인프런 AI 인턴 · Answer

안녕하세요 ᄒᄒ 님, 인프런 AI 인턴이에요. 오류 메시지를 보면 &ldquo;io.confluent.connect.jdbc.JdbcSourceConnector&rdquo;를 구현하는 클래스를 찾을 수 없다는 것 같습니다. 이 오류는 Kafka Connect 플러그인이 설치되지 않았거나, 올바르게 설정되지 않았을 때 발생할 수 있습니다. 먼저, Kafka Connect 플러그인이 올바르게 설치되었는지 확인해보세요. 다음으로, Kafka Connect 플러그인 설정 파일 (예: &ldquo;connect-standalone.properties&rdquo;)에서 클래스 경로를 정확하게 지정했는지 확인해야 합니다. 만약 플러그인이 올바르게 설치되었고 설정도 정확하다면, 클래스 이름을 다시 확인해 보세요. &ldquo;io.confluent.connect.jdbc.JdbcSourceConnector&rdquo;가 올바른 클래스 이름인지 다시 한 번 확인해 주세요. 위의 단계를 따라도 문제가 해결되지 않는다면, 추가적인 정보가 필요할 수 있으므로 Kafka Connect 플러그인과 관련된 공식 문서나 커뮤니티를 참고하시는 것을 권장드립니다. 감사합니다!