我一直在試圖連接使用卡夫卡卡夫卡連接api.Kafka版本elasticsearch是0.11.0.0.These是我遵循的步驟:
1.Buiding Elasticsearch連接器:
https://github.com/confluentinc/kafka-connect-elasticsearch.git
2.Build連接器
$ cd kafka-connect-elasticsearch
$ mvn clean package
3.最後運行腳本:
$ bin/connect-standalone.sh config/connect-standalone.properties config/elasticsearch-connect.properties
它拋出以下異常:
Exception in thread "main" java.lang.NoSuchMethodError: com.google.common.collect.Sets$SetView.iterator()Lcom/google/common/collect/UnmodifiableIterator;
at org.reflections.Reflections.expandSuperTypes(Reflections.java:380)
at org.reflections.Reflections.<init>(Reflections.java:126)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:221)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:198)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:159)
at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:47)
at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:68)
不明白什麼地方出了錯。
也許只是嘗試安裝包括0.11和Elasticsearch連接器的Confluent Open Source發行版,並按照快速入門http://docs.confluent.io/current/connect/connect-elasticsearch/docs/elasticsearch_connector。 html –
我已經完成了整個代碼而沒有使用Confluent,現在切換它並不是我正在計劃的內容。是不是有解決方案? –
這只是一個建議,可以幫助您確定問題是您的設置,構建環境還是Confluent ES連接器本身。 –