I'm trying to configure a Kafka source in RisingWave to include metadata columns such as Key, Offset, Partition, and Timestamp. When I use the INCLUDE statement as shown in the documentation example, I encounter an error. How can I correctly include these metadata columns in the Kafka source configuration?
Neil
Asked on Mar 11, 2024
Place the INCLUDE statement before the WITH clause in the source configuration.
Separate each metadata column with its own INCLUDE statement on separate lines.
Ensure that the metadata columns are specified correctly in the INCLUDE statement.
