Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-3708

Debezium server crashes when deleting a record from a SQLServer table (redis sink)

    XMLWordPrintable

Details

    Description

      When deleting record(s) from an observed table, the server crashes with this error:

      delete from emp where empno = 83 

       

      Seems that the issue stemmed from the Redis sink: 

      2021-07-05 12:42:17,132 INFO [io.deb.ser.ConnectorLifecycle] (pool-7-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:80)
       at io.debezium.server.redis.RedisStreamChangeConsumer.handleBatch(RedisStreamChangeConsumer.java:118)
       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:145)
       at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
       at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
       at java.base/java.lang.Thread.run(Thread.java:829)

       

      Attachments

        Activity

          People

            ccranfor@redhat.com Chris Cranford
            yossish Yossi Shirizli
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: