2017-10-26 1 views
0

나는 kafka jdbc 합류 커넥터 3.x를 사용하여 Oracle에서 데이터를 가져 와서 Kafka 서버에 게시했습니다.카프카 합류 JDBC 커넥터가 유효하지 않은 값

속성 파일 구성은 다음과 같습니다.

name=demo-jdbc-source 
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector 
connection.url=jdbc://db_config 
table.whitelist=Table_test 
tasks.max=1 
mode=incrementing 
incrementing.column.name=TEST_ID 
topic.prefix=jdbc-source- 

같은 오류가 그것을 실행하는 동안 : 그것은 JDBC 커넥터 JAR처럼 보이는

> Invalid value io.confluent.connect.jdbc.JdbcSourceConnector for 
> configuration connector.class: Class 
> io.confluent.connect.jdbc.JdbcSourceConnector could not be found. 

답변

1

가 카프카 Connect에서 찾을 수 없습니다.

Confluent Platform 또는 JDBC Connector을 기존 Kafka 배포와 함께 사용하고 있습니까? 전자에서는 경로가 자동으로 설정됩니다. 후자의 경우 kafka-connect-jdbc-3.3.0.jar이 CLASSPATH에 있는지 확인해야합니다 (또는 Connect 작업자 구성에서 plugin.path configuration option을 사용하십시오).

+0

저는 가장 좋은 방법 인 JDBC 커넥터를 사용하고 있습니까? 합류 플랫폼 또는 JDBC 커넥터 사용! – Raju

+1

Confluent Platform에는 JDBC 커넥터가 포함되어 있습니다. 따라서 Confluent Platform을 사용하거나 다른 곳에서 Kafka를 사용하고 JDBC 커넥터를 별도로 다운로드 할 수 있습니다. –

관련 문제