shmoli / ccloud_metrics_source

Kafka connect source connector to grab runtime metrics from Confluent Cloud and publish into Kafka.
Apache License 2.0
9 stars 3 forks source link

Connector is not getting registered #5

Open kafka75 opened 3 years ago

kafka75 commented 3 years ago

Connectore created .. Maven package created.. Included the fat dependency.jar as well. Source connector starts 3 topics are created.. When a start the curl command the task. is FAILING curl localhost:8083/connectors/CCloudMetrics/status | jq % Total % Received % Xferd Average Speed Time Time Time Current Dload Upload Total Spent Left Speed 100 1431 100 1431 0 0 14280 0 --:--:-- --:--:-- --:--:-- 14310 { "name": "CCloudMetrics", "connector": { "state": "RUNNING", "worker_id": "cmetrics:8083" }, "tasks": [ { "id": 0, "state": "FAILED", "worker_id": "cmetrics:8083", "trace": "java.lang.NoClassDefFoundError: com/mashape/unirest/request/HttpRequest\n\tat com.github.shmoli.kafka.connect.source.metricsapi.MetricsAPISourceTask.start(MetricsAPISourceTask.java:55)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:834)\nCaused by: java.lang.ClassNotFoundException: com.mashape.unirest.request.HttpRequest\n\tat java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:471)\n\tat java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:589)\n\tat org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass(PluginClassLoader.java:104)\n\tat java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:522)\n\t... 9 more\n" } ], "type": "source" error.txt

shmoli commented 2 years ago

Can you try to replace the install folder with only the fat jar and restart. Should resolve this issue.