-
Bug
-
Resolution: Done
-
Major
-
None
-
None
We upgraded debezium to 1.1.0, and then it couldn't recover from the situation when received a message from wal2json like this:
{ "xid": 29988430, "timestamp": "2020-03-27 14:47:31.400178+08", "change": [] }
A NullPointerException is thrown:
at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.lambda$execute$0(PostgresStreamingChangeEventSource.java:128) at io.debezium.connector.postgresql.connection.wal2json.StreamingWal2JsonMessageDecoder.doProcessMessage(StreamingWal2JsonMessageDecoder.java:259) ...
We never met this exception at version 0.9.x, so I guess it may cause by code refactor?