내가 연주하고 파일과 나는 몇 가지 예제를 실행하고 싶었다. 카프카 연결은 - <strong>Conluent 플랫폼/카프카 연결</strong>와 유사한 것들로 소스 커넥터 오류
나는 here에서 빠른 시작을 따랐다. 그것은 의미- 설치 플루 플랫폼 (V3.2.1)
- 실행 사육사, 카프카 중개인 및 스키마 등록 (카프카 연결 witk) 파일 데이터를 읽기위한
- 실행 예를
내가 달릴 이 명령 (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"
그것은 [OpenTSDB 커넥터]과 뭔가 갖는다 (https://github.com/jeff-svds/kafka-connect-opentsdb). 내 클래스 패스에 JAR 파일을 포함 시키면 (지침에 따라) OpenTSDB 커넥터와 마찬가지로 File source 커넥터와 같은 출력을 얻을 수 있습니다. 그것이 설정되지 않은 경우 FileSource 커넥터를 실행할 수 있지만 OpenTSDB는 하나가 아닙니다 (클래스 패스에없는 원인으로 인해 커넥터를 찾을 수 없습니다). 정확히 설정하는 방법을 모릅니다. – Nerxis