kafka-connect-hdfs icon indicating copy to clipboard operation
kafka-connect-hdfs copied to clipboard

Facing issue while trying to get data from postgres sql into kafka topics using debezium plugin

Open Snehil-upes opened this issue 3 years ago • 1 comments

Here is the issue that I am facing: ERROR WorkerSourceTask{id=Trail-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:187) org.apache.kafka.connect.errors.ConnectException: Invalid metric name 'debezium.postgres:type=connector-metrics,context=snapshot,server=localhost:5432/snehildb' at io.debezium.metrics.Metrics.metricName(Metrics.java:92) at io.debezium.metrics.Metrics.(Metrics.java:34) at io.debezium.pipeline.metrics.PipelineMetrics.(PipelineMetrics.java:44) at io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics.(SnapshotChangeEventSourceMetrics.java:46) at io.debezium.pipeline.metrics.DefaultChangeEventSourceMetricsFactory.getSnapshotMetrics(DefaultChangeEventSourceMetricsFactory.java:21) at io.debezium.pipeline.ChangeEventSourceCoordinator.start(ChangeEventSourceCoordinator.java:82) at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:215) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234) 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:834)

Snehil-upes avatar Apr 10 '21 12:04 Snehil-upes

@Snehil-upes Please close this and open the issue in the appropriate Debezium github repository

OneCricketeer avatar Jun 07 '21 12:06 OneCricketeer