Details
-
Bug
-
Resolution: Done
-
Critical
-
0.10.0.Alpha2
-
None
Description
connect_1 | java.lang.NullPointerException connect_1 | at io.debezium.connector.mongodb.SourceInfo.database(SourceInfo.java:381) connect_1 | at io.debezium.connector.AbstractSourceInfoStructMaker.commonStruct(AbstractSourceInfoStructMaker.java:54) connect_1 | at io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker.struct(MongoDbSourceInfoStructMaker.java:37) connect_1 | at io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker.struct(MongoDbSourceInfoStructMaker.java:15) connect_1 | at io.debezium.connector.mongodb.SourceInfo.sourceInfoStructFor(SourceInfo.java:246) connect_1 | at io.debezium.connector.mongodb.SourceInfo.sourceInfoStructForEvent(SourceInfo.java:229) connect_1 | at io.debezium.connector.mongodb.Replicator.lambda$recordCurrentOplogPosition$1(Replicator.java:206) connect_1 | at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:275) connect_1 | at io.debezium.connector.mongodb.Replicator.recordCurrentOplogPosition(Replicator.java:203) connect_1 | at io.debezium.connector.mongodb.Replicator.run(Replicator.java:152) connect_1 | at io.debezium.connector.mongodb.MongoDbConnectorTask.lambda$start$1(MongoDbConnectorTask.java:127) connect_1 | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) connect_1 | at java.util.concurrent.FutureTask.run(FutureTask.java:266) connect_1 | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) connect_1 | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) connect_1 | at java.lang.Thread.run(Thread.java:748)
The code assumes there's always be a collection id, but it's not the case when receiving noop events.
