Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1377

Null pointer exception when trying to get ReplicationSlotInfo on Postgres Debezium Connector

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • None
    • None
    • None
    • None

      I have created a postgres debezium connector, the connector runs fine but after some time the flowing error is thrown.

      java.lang.NullPointerException
      	at io.debezium.connector.postgresql.connection.PostgresConnection.getReplicationSlotInfo(PostgresConnection.java:141)
      	at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:96)
      	at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:49)
      	at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:198)
      	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)
      

      Please help me out in knowing why this is happening and how to resolve it.

              Unassigned Unassigned
              yanamadala.prakash@oyorooms.com Yanamadala JaiPrakash (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: