-
Bug
-
Resolution: Done
-
Critical
-
0.9.5.Final
-
None
Getting an nullpointerexception:
java.lang.NullPointerException\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getReplicationSlotInfo(PostgresConnection.java:141)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:96)\n\tat io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:49)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:157)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat java.lang.Thread.run(Thread.java:745)\n
The methos `fetchReplicationSlotInfo` return a null value in some cases. So a null value is valid, but calling `.equals` on a null object in the `getReplicationSlotInfo` method will throw the NullPointerException
