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 failed. with Task threw an uncaught and unrecoverable exception #11

Open bhushayya opened 11 months ago

bhushayya commented 11 months ago

I'm Trying to implement Kafka to AppDynamics metrics. While following the doc betting below error message.

[2023-09-28 07:06:28,151] ERROR [CCloudMetrics|task-0] WorkerSourceTask{id=CCloudMetrics-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:196) java.lang.IllegalArgumentException: argument "src" is null at com.fasterxml.jackson.databind.ObjectMapper._assertNotNull(ObjectMapper.java:4693) at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3470) at com.github.shmoli.kafka.connect.source.metricsapi.utils.GitProperties.getProperties(GitProperties.java:42) at com.github.shmoli.kafka.connect.source.metricsapi.MetricsAPIHttpClient.(MetricsAPIHttpClient.java:65) at com.github.shmoli.kafka.connect.source.metricsapi.MetricsAPISourceTask.start(MetricsAPISourceTask.java:55) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:271) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:187) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:244) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:73) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) [2023-09-28 07:06:28,152] INFO [CCloudMetrics|task-0] [Producer clientId=connector-producer-CCloudMetrics-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1300) [2023-09-28 07:06:28,154] INFO [CCloudMetrics|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:693) [2023-09-28 07:06:28,154] INFO [CCloudMetrics|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:697) [2023-09-28 07:06:28,154] INFO [CCloudMetrics|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:703) [2023-09-28 07:06:28,154] INFO [CCloudMetrics|task-0] App info kafka.producer for connector-producer-CCloudMetrics-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)