基于Kafka Topic创建KsqlDB Stream遇语法错误，求正确创建方法

问题原因 #

错误提示中的‘是中文全角左单引号，而KSQL要求使用英文半角单引号（'）。你语句里KAFKA_TOPIC = ‘orders’的引号是中文格式，导致解析器无法识别为合法字符串，触发了InputMismatchException。

修正后的创建语句 #

CREATE STREAM orders_stream (
    OrderId BIGINT,
    Description VARCHAR
  ) WITH (
    KAFKA_TOPIC = 'orders',
    VALUE_FORMAT = 'JSON'
  );

注意事项 #

• SQL语法中所有字符串、标识符的引用必须使用英文半角符号，包括单引号、双引号、逗号、括号等。
• 中文全角符号会被KSQL解析器判定为无效输入，引发语法匹配错误。

内容的提问来源于stack exchange，提问作者Eugene Goldberg