Kafka Connect - 文件源連接器錯誤

我正在玩Conluent Platform/Kafka Connect和類似的東西，我想運行幾個例子。Kafka Connect - 文件源連接器錯誤

我跟着從here快速啓動。這意味着：

安裝匯合平臺（V3.2.1）
運行動物園管理員，卡夫卡經紀人和Schema註冊
運行例如讀取文件中的數據（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 67行上的文件是這樣的：Time time = Time.SYSTEM;，但我不知道，爲什麼它應該會導致任何錯誤。有任何想法嗎？我錯過重要的東西嗎？

我的工作環境：

Hortonworks沙盒[HDP 2.5.0.0-1245]
CentOS版本6.8
的Java：OpenJDK的版本「1.8.0_121」

來源

2017-05-04 Nerxis

它與[OpenTSDB連接器]（https://github.com/jeff-svds/kafka-connect-opentsdb）有關。當我將JAR文件包含在我的類路徑中（根據說明）時，我得到了兩個相同的輸出（如文件源連接器與OpenTSDB連接器一樣）。當它沒有設置時，我可以運行文件源連接器但不是OpenTSDB之一（連接器未找到，因爲它不在classpath中）。不知道如何設置正確的.. – Nerxis

我見面上的同一個問題「線路67上的ConnectStandalone.java文件是這樣的：Time time = Time.SYSTEM」

這也許是該OpenTSDB連接器取決於版本卡夫卡的客戶端 - versionA.jar正在./libs從卡夫卡的客戶端 - versionB.jar不同。

來源

2017-05-23 11:06:15

這正是問題，這是所有關於版本。最後，我使用_build.sbt_文件中定義的不同版本構建了此連接器，並且它有所幫助！謝謝！ – Nerxis

Kafka Connect - 文件源連接器錯誤

回答

相關問題