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

Error with UUID-typed collection column

    XMLWordPrintable

Details

    Description

      Encountered the following error when sending out ChangeEvent Kafka messages with Collection<UUID/TIMEUUID> type column:

      14:26:24.117 [pool-4-thread-4] ERROR i.d.c.c.CassandraConnectorTask - Encountered exception while running Change Event Queue Processor; stopping all processors in Cassandra Connector Task
      org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type STRING: class java.util.UUID for field: "null"
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:245) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:258) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:216) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:203) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.CellData.record(CellData.java:73) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.RowData.record(RowData.java:53) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.Record.buildValue(Record.java:87) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.KafkaRecordEmitter.toProducerRecord(KafkaRecordEmitter.java:72) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.KafkaRecordEmitter.emit(KafkaRecordEmitter.java:55) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.QueueProcessor.processEvent(QueueProcessor.java:97) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.QueueProcessor.process(QueueProcessor.java:59) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.AbstractProcessor.start(AbstractProcessor.java:61) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at io.debezium.connector.cassandra.CassandraConnectorTask$ProcessorGroup.lambda$start$0(CassandraConnectorTask.java:200) ~[debezium-connector-cassandra-1.3.0.Beta1-jar-with-dependencies.jar:1.3.0.Beta1]
      	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_231]
      	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_231]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_231]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_231]
      	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_231] 

      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:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: