inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

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

Kafka Connect 설치 ②

JDBC source connector를 못찾는 문제

876

inflearn.002

작성한 질문수 1

2

안녕하세요 선생님 수업 잘 듣고 있습니다

제 환경은 Windows 11이고 업로드 해주신 설치 파일을 다운로드 하여 수업을 진행해보고 있습니다.

kafka jdbc connector를 plugin.path에 등록해 두어도 프로그램이 탐색을 못하고 있어 계속 처음부터 다시 해보다가 여쭤봅니다.

아래는 plugin.path 이고 주소는 kafka-connect-jdbc-10.5.1 파일이 있는 폴더 경로를 복사하여 붙여넣은 것입니다.

\etc\kafka\connect-distributed.properties

plugin.path=\C:\Works\Kafka\kafka-connect-jdbc\lib

 

아래는 source connector 등록시 나오는 오류입니다.

"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='6.1.0-ccs', encodedVersion=6.1.0-ccs, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector, name='org.apache.kafka.connect.file.FileStreamSourceConnector', version='6.1.0-ccs', encodedVersion=6.1.0-ccs, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorCheckpointConnector, name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector', version='1', encodedVersion=1, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector',

localhost:8083/connector-plugins 에서도 jdbc connector가 보이지 않습니다.

{
        "class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
        "type": "sink",
        "version": "6.1.0-ccs"
    },
    {
        "class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
        "type": "source",
        "version": "6.1.0-ccs"
    },
    {
        "class": "org.apache.kafka.connect.mirror.MirrorCheckpointConnector",
        "type": "source",
        "version": "1"
    },
    {
        "class": "org.apache.kafka.connect.mirror.MirrorHeartbeatConnector",
        "type": "source",
        "version": "1"
    },
    {
        "class": "org.apache.kafka.connect.mirror.MirrorSourceConnector",
        "type": "source",
        "version": "1"
    }

 

그리고 .\share\java\kafka에서는 mysql 드라이버를 복사해두었습니다.

 

혹시나 해서 confluent랑 kafka의 모든 connect-distributed.properties 파일에는 다 plugin.path를 설정해 두었고.. 오류메시지가 나오는 곳에서 available connectors 목록이 있는 위치에 jdbc connector를 붙여넣어 보기도 했습니다.. 그런데도 조회가 안되어서 놓친 부분이 어디있을까 하여 여쭤봅니다. 확인 부탁드립니다~

JPA spring-cloud spring-boot architecture msa Kafka

답변 0

kafka 업데이트 강의 듣고 시포요

0

116

2

강의 교안

0

107

2

마이크로서비스간 통신 시, 인증 처리

0

117

2

api gateway 에서 인증 처리

0

76

1

섹션 19 질문드립니다

0

87

2

강의 자료 업데이트

0

105

2

부하분산 강의 섹션

0

67

1

강의자료는 어디에서?

0

99

2

강의 자료는 어디서 다운 받을 수 있나요?

0

132

2

전체 사용자 조회시 오류

0

66

1

혹시 pk 외 별도의 id 를 부여한 이유가 있을까요 ??

0

122

2

학습 방향

0

106

2

카프카 커넥터 사용 목적 문의

0

93

2

kafka 강의

0

119

2

서비스 디스커버리 종류

0

91

2

강의 자료에 대해서 궁금해요

0

126

2

GlobalFilter, LoggingFilter가 동작하지 않습니다.

0

97

2

Kafka Source Connect 버전 에러

0

98

2

소스커넥터는 사용안한 거 맞죠?

0

86

2

강의자료 업데이트 문의

0

101

2

강의에서 BCryptPasswordEncoder 에 역할(5-2)

0

64

1

강의 업데이트 계획이 궁금합니다.

0

122

2

MSA 애플리케이션에 Spring Web과 Spring Data JPA를 사용하는 것이 바람직한지 궁금합니다. (MSA 설계와 관련된 질문입니다)

0

168

2

어떤 것이 업데이트 된 건가요?

0

170

2