proton
proton copied to clipboard
Fix issue #912: Support data_schema in CREATE EXTERNAL STREAM (Kafka)
Summary
This PR fixes the issue where data_schema was not recognized in CREATE EXTERNAL STREAM for Kafka.
Changes
- Added
data_schemato theExternalStreamSettings. - Updated
InterpreterCreateQueryto extract and applydata_schema. - Fixed schema auto-derivation from Avro format.
- Modified
ParserCreateQueryto properly handledata_schema.
Testing
- Successfully created an external stream with
data_schema:CREATE EXTERNAL STREAM example SETTINGS type = 'kafka', brokers = 'localhost:9092', topic = 'my-topic', data_format = 'Avro', data_schema = 'my_avro_schema';