2017-05-04 7 views
0

내가 연주하고 파일과 나는 몇 가지 예제를 실행하고 싶었다. 카프카 연결은 - <strong>Conluent 플랫폼/카프카 연결</strong>와 유사한 것들로 소스 커넥터 오류

나는 here에서 빠른 시작을 따랐다. 그것은 의미

  1. 설치 플루 플랫폼 (V3.2.1)
  2. 실행 사육사, 카프카 중개인 및 스키마 등록
  3. (카프카 연결 witk) 파일 데이터를 읽기위한
  4. 실행 예를

내가 달릴 이 명령 (3 번) :

[[email protected] confluent-3.2.1]# ./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka/connect-file-source.properties 

하지만이 결과를 가지고 :

SLF4J: Class path contains multiple SLF4J bindings. 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/etc/kafka-connect-opentsdb/target/scala-2.11/kafka-connect-opentsdb-assembly-0.0.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/share/java/kafka-connect-elasticsearch/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/share/java/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/share/java/kafka-connect-s3/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/share/java/kafka-connect-storage-common/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: Found binding in [jar:file:/root/confluent-3.2.1/share/java/kafka/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class] 
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 
SLF4J: Actual binding is of type [ch.qos.logback.classic.util.ContextSelectorStaticBinder] 
Exception in thread "main" java.lang.NoSuchFieldError: SYSTEM 
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:67) 

ConnectStandalone.java 파일의 내용은 다음과 같습니다. Time time = Time.SYSTEM;, 그러나 이것은 왜 오류가 발생해야하는지 모르겠습니다. 어떤 아이디어? 중요한 것을 놓친 건가요?

내 작업 환경 :

  • 호튼 웍스 샌드 박스 [HDP는 2.5.0.0-1245]
  • 에 CentOS 6.8
  • 자바를 해제 : 오픈 JDK 버전 내가 만나 "1.8.0_121"
+0

그것은 [OpenTSDB 커넥터]과 뭔가 갖는다 (https://github.com/jeff-svds/kafka-connect-opentsdb). 내 클래스 패스에 JAR 파일을 포함 시키면 (지침에 따라) OpenTSDB 커넥터와 마찬가지로 File source 커넥터와 같은 출력을 얻을 수 있습니다. 그것이 설정되지 않은 경우 FileSource 커넥터를 실행할 수 있지만 OpenTSDB는 하나가 아닙니다 (클래스 패스에없는 원인으로 인해 커넥터를 찾을 수 없습니다). 정확히 설정하는 방법을 모릅니다. – Nerxis

답변

0

에서 동일한 문제 "선 67 ConnectStandalone.java 파일이 있습니다 : 시간 시간 = Time.SYSTEM"

그것은 OpenTSDB 커넥터의 버전에 의존한다는 어쩌면이다 카프카 - 클라이언트 - versionA.jar는 ./libs에서 카프카 - 클라이언트 - versionB.jar 다릅니다.

+0

정확하게 문제였습니다. 버전에 관한 것입니다. 마지막으로 _build.sbt_ 파일에 정의 된 다른 버전으로이 커넥터를 만들었습니다. 감사! – Nerxis