如何正确创建基于Kafka主题的KsqlDB流

Question

我正试图以以下方式创建KsqlDB流(使用KSQL CLI(：

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

我得到这个错误：

line 5:19: mismatched input '‘' expecting {'NULL', 'TRUE', 'FALSE', '-', STRING, INTEGER_VALUE, DECIMAL_VALUE, FLOATING_POINT_VALUE, VARIABLE}
Statement: CREATE STREAM orders_stream (
Ordered BIGINT,
Description VARCHAR
) WITH (
KAFKA_TOPIC = ‘orders’,
VALUE_FORMAT = 'JSON'
);
Caused by: line 5:19: mismatched input '‘' expecting {'NULL', 'TRUE', 'FALSE',
'-', STRING, INTEGER_VALUE, DECIMAL_VALUE, FLOATING_POINT_VALUE, VARIABLE}
Caused by: org.antlr.v4.runtime.InputMismatchException

我似乎在这里找不到问题。感谢提供的任何帮助

Answer 1

只需将'orders'更改为'orders'即可。

ksql>创建流订单_流(

OrderId BIGINT，描述VARCHAR(WITH(KAFKA_TOPIC='orders'，PARTITIONS=1，REPLICAS=1，VALUE_FORMAT='JSON'(；

消息

流已创建

ksql>