-
-
Notifications
You must be signed in to change notification settings - Fork 40
Description
I followed below steps.
- Clone this project and create a jar using command mvn clean package -DskipTests
- There are two jar is created. first one is elastic-source-connect-1.5.5.jar and second is elastic-source-connect-1.5.5-jar-with-
dependencies.jar. - Copied first jar(elastic-source-connect-1.5.5.jar) into kafka/libs folder
- Restart Kafka
- Start connector by following command-
bin/connect-distributed.sh config/connect-distributed.properties - Hit following api Curl
curl --location 'http://localhost:8083/connectors' \ --header 'Content-Type: application/json' \ --data-raw '{ "name": "elastic-connector", "config": { "connector.class": "com.github.dariobalinzo.ElasticSourceConnector", "tasks.max": "1", "es.host": "99.99.99.120", "es.port": "9200", "index.prefix": "employee", "topic.prefix": "data", "incrementing.field.name": "timestamp" } }'
Now it gives following error.
(com.github.dariobalinzo.ElasticSourceConnectorConfig:370)
[2024-07-05 14:59:44,611] ERROR [elastic-syslog14|worker] WorkerConnector{id=elastic-syslog14} Error while starting connector (org.apache.kafka.connect.runtime.WorkerConnector:200)
java.lang.NoClassDefFoundError: org/apache/http/client/CredentialsProvider
at com.github.dariobalinzo.elastic.ElasticConnectionBuilder.build(ElasticConnectionBuilder.java:77)
at com.github.dariobalinzo.ElasticSourceConnector.start(ElasticSourceConnector.java:95)
at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:192)
at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:217)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:376)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:357)
at org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:144)
at org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:122)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:236)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: java.lang.ClassNotFoundException: org.apache.http.client.CredentialsProvider
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:525)
... 14 more
Please help me to resolve this issue.