Details
-
Bug
-
Resolution: Done
-
Major
-
1.5.2.Final
-
None
-
False
-
False
-
Undefined
Description
I'm using debezium server to CDC the table data from oracle to pulsar.when I run the script run.sh,I got the error
message " 2021-06-07 17:39:09,887 INFO [io.deb.ser.ConnectorLifecycle] (pool-3-thread-1) Connector completed: success = 'false', message = 'Stopping connector after error in the application's handler method: Unexpected data type 'null'', error = '{}': io.debezium.DebeziumException: Unexpected data type 'null' at io.debezium.server.BaseChangeConsumer.getString(BaseChangeConsumer.java:71) at io.debezium.server.pulsar.PulsarChangeConsumer.handleBatch(PulsarChangeConsumer.java:123) at io.debezium.embedded.ConvertingEngineBuilder.lambda$notifying$2(ConvertingEngineBuilder.java:83) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:821) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:142) 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)"
I think the reason is the source table has none primary key.
Then I got the solution by Naros to use oracle connector parameter "message.key.columns".
Why the property "debezium.sink.pulsar.null.key" can not resove this?
