kafka mongodb 싱크 커넥터가 시작되지 않음

Question

나는 confluent_3.3.0을 설치했으며 zookeper, schema-registry 및 kafka 브로커를 시작했습니다. 그리고 싱크 커넥터를 실행 링크 https://github.com/RADAR-CNS/MongoDb-Sink-Connector

아래에서 다운로드 MongoDB를 커넥터

./bin/connect-standalone etc/kafka/connect-standalone.properties /home/username/mongo-connect-test/kafka-connect-mongodb/quickstart-couchbase-sink.properties

내가 커넥터 오류가 발생한 후 중지 오류 ERROR 아래 얻고 명령 아래 사용 (org.apache.kafka.connect.cli .ConnectStandalone : 91) 는 java.lang.IllegalAccessError : 클래스 org.radarcns.mongodb.MongoDbSinkConnector

에서 필드 org.apache.kafka.common.config.ConfigDef.NO_DEFAULT_VALUE에 액세스하려고

독서에 감사드립니다!

Answer 1

이 커넥터는 최신 버전에서 kafka-clients API의 이전 버전을 사용합니다. 구체적으로는 0.11.0.0이

이 문제를 해결하려면 아파치 카프카를 사용하는 아파치 카프카 버전 >= 0.11.0.0

플루 플랫폼 버전 3.3.0에 존재하지 않는 클래스 org.apache.kafka.common.config.AbstractConfig의 생성자에 따라되면, 권장되는 방법은 업데이트하는 것 최신 버전의 Apache Kafka API를 사용하는 커넥터 코드