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

Cassandra CDC failed to deserialize list<UserType> column correct

    XMLWordPrintable

    Details

      Description

      For a column definition like List<UserDefinedType>, Cassandra Connector failed to deserialize it's value from snapshot query results correctly.

      Error log:

      Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type STRUCT: class java.nio.HeapByteBuffer for field: "null"
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:245)
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213)
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:258)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
      	at io.debezium.connector.cassandra.CellData.record(CellData.java:73)
      	at io.debezium.connector.cassandra.RowData.record(RowData.java:53)
      	at io.debezium.connector.cassandra.Record.buildValue(Record.java:87)
      	at io.debezium.connector.cassandra.KafkaRecordEmitter.toProducerRecord(KafkaRecordEmitter.java:72)
      	at io.debezium.connector.cassandra.KafkaRecordEmitter.emit(KafkaRecordEmitter.java:56)
      	... 9 more 

       

        Attachments

          Activity

            People

            Assignee:
            bingqinzhou Bingqin Zhou
            Reporter:
            bingqinzhou Bingqin Zhou
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Dates

              Created:
              Updated:
              Resolved: