I'm trying to create a Kafka source in RisingWave with the following SQL command:
CREATE SOURCE IF NOT EXISTS test
WITH (
connector='kafka',
topic='mytopic',
properties.bootstrap.server='redpanda.redpanda.svc.cluster.local:9093',
scan.startup.mode='latest'
) FORMAT PLAIN ENCODE PROTOBUF (
message = 'SomeSchemaInPBFile',
location = '<s3://bucketname/all_schemas.pb>'
);However, I'm encountering an error:
ERROR: QueryError: sql parser error: expect description of the formatI'm not sure what's causing this error or how to fix it. Can someone help me understand what I'm doing wrong?
Yannick Koechlin
Asked on Sep 29, 2023
The error message expect description of the format indicates that the SQL parser is expecting a description of the data format but isn't finding it. This could be due to a syntax error or missing clause in your CREATE SOURCE statement. To resolve this error, ensure that you have correctly specified the FORMAT clause and that there are no hidden characters or syntax issues. Additionally, if your source name contains special characters like -, make sure to enclose the name in double quotes. If the issue persists, check the logs from the frontend node for more detailed error messages.