RisingWave Community - How to include key, offset, partition, etc. columns in Kafka source configuration?

RisingWave Community

risingwave-community.slack.com

troubleshooting

How to include key, offset, partition, etc. columns in Kafka source configuration?

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.

Mar 11, 2024Edited by