troubleshooting

How to resolve the unsupported type in Avro error when streaming data from Confluent Kafka to RisingWave with numeric columns?

I'm getting the error ERROR: QueryError: internal error: unsupported type in Avro: Ref { name: Name { name: "VariableScaleDecimal", namespace: Some("io.debezium.data") } } when trying to create table on RisingWave due to numeric columns. How can I resolve this issue?

Da

Dat Nguyen

Asked on Jun 12, 2023

  • The unsupported type in Avro error occurs when there is a numeric column with variable scale (defined with the numeric) in the Avro schema.
  • To resolve this issue, you can temporarily work around it by changing the data type in the source database from numeric to numeric(x, y) where x and y are the precision and scale of the numeric column.

Example:

-- Before
CREATE TABLE my_table (
    my_numeric_column NUMERIC
);

-- After
CREATE TABLE my_table (
    my_numeric_column NUMERIC(x, y)
);
  • This workaround should allow you to stream data from Confluent Kafka to RisingWave without encountering the unsupported type error.
Jun 15, 2023Edited by