Kafka разъем для упругого поиска исключение - PullRequest
Новая
       7

Kafka разъем для упругого поиска исключение

0 голосов
/ 21 февраля 2019

У меня возникло исключение, когда я запускаю свой соединитель kafka для эластичного поиска.Я установил сливной соединитель kafka для упругого поиска и настроил его следующим образом:

{ "name": "ElasticsearchSinkConnector2", "config":{ "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector", "topics": "test", "tasks.max": 1, "connection.url": "elasticsearch:9200", "type.name": "log", "key.ignore":true, "schema.ignore":true } }

Но получил это исключение: 

java.lang.NoClassDefFoundError: io/searchbox/action/Action
atio.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:118)
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:49)
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:49)
at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:302)
atorg.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:191)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: io.searchbox.action.Action
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 11 more`
...