This topic describes how to modify the schema of a RisingWave source or table.
mv1
that is created with this statement:
my_kafka_source
:
mv1
does not contain the new column new_col
. If you want to pick up this new column, you’ll need to create a new materialized view.
data_format
and data_encode
. Furthermore, when refreshing the schema registry of a source, it is not allowed to drop columns or change types.REFRESH SCHEMA
clause of ALTER SOURCE
can also be used to refresh the schema of a source.