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

            zhou.bing@husky.neu.edu Bingqin Zhou (Inactive)
            zhou.bing@husky.neu.edu Bingqin Zhou (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: