-
Bug
-
Resolution: Done
-
Major
-
3.0.7.Final, 3.1.0.Alpha1
-
None
-
False
-
None
-
False
-
-
When using primary key mode RECORD_VALUE, a DELETE event will result in a NullPointerException because the lookup is based on the AFTER only.
java.lang.NullPointerException: Cannot invoke "org.apache.kafka.connect.data.Struct.schema()" because the return value of "org.apache.kafka.connect.data.Struct.getStruct(String)" is null
at io.debezium.connector.jdbc.JdbcKafkaSinkRecord.applyRecordValueAsPrimaryKey(JdbcKafkaSinkRecord.java:179)
at io.debezium.connector.jdbc.JdbcKafkaSinkRecord.readSinkRecordKeyData(JdbcKafkaSinkRecord.java:94)
at io.debezium.connector.jdbc.JdbcKafkaSinkRecord.<init>(JdbcKafkaSinkRecord.java:62)
at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78)
at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:128)
at io.debezium.connector.jdbc.integration.AbstractJdbcSinkTest.consume(AbstractJdbcSinkTest.java:179)
at io.debezium.connector.jdbc.integration.AbstractJdbcSinkTest.consume(AbstractJdbcSinkTest.java:170)
at