我无法在kafka ksql中创建表

9wbgstp7  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(685)

这是我的sql,我不知道怎么了

CREATE TABLE memo_src (
    'id' VARCHAR PRIMARY KEY,
    'title' VARCHAR,
    'cover_image' VARCHAR
  ) WITH (
    KAFKA_TOPIC = 'memo.memorandum.memorandum_info',
    VALUE_FORMAT='AVRO'
);

那就提示我如下

extraneous input ''id'' expecting {'EMIT', 'CHANGES', 'INTEGER', 'DATE', 'TIME', 'TIMESTAMP', 'INTERVAL', 'YEAR', 'MONTH', 'DAY', 'HOUR', 'MINUTE', 'SECOND', 'ZONE', 'PARTITION', 'STRUCT', 'EXPLAIN', 'ANALYZE', 'TYPE', 'TYPES', 'SHOW', 'TABLES', 'COLUMNS', 'COLUMN', 'PARTITIONS', 'FUNCTIONS', 'FUNCTION', 'ARRAY', 'MAP', 'SET', 'RESET', 'SESSION', 'KEY', 'SINK', 'SOURCE', 'IF', IDENTIFIER, DIGIT_IDENTIFIER, QUOTED_IDENTIFIER, BACKQUOTED_IDENTIFIER}
Statement: CREATE TABLE memo_src (
    'id' VARCHAR PRIMARY KEY,
    'title' VARCHAR,
    'cover_image' VARCHAR
  ) WITH (
    KAFKA_TOPIC = 'memo.memorandum.memorandum_info',
    VALUE_FORMAT='AVRO'
);
rslzwgfq

rslzwgfq1#

你的身份证、头衔和封面图片不应该用引号括起来。这就是为什么编译器声明它不需要标记'id'。

相关问题