如何在ksqldb.io中创建表而不导致语法错误

Question

流量ksql的当前状态使得很难理解在哪个版本中支持/拒绝/强制/可选哪个功能。Confluent没有明确版本参考的文档并没有让它变得更好，所以我被困在这里：

create table gtest (ID varchar PRIMARY KEY) with (kafka_topic = 'g', value_format='avro');

创建语法错误

line 1:32: mismatched input 'PRIMARY' expecting {',', ')'}
Statement: create table gtest (ID varchar PRIMARY KEY) with (kafka_topic = 'g', value_format='avro');
Caused by: line 1:32: mismatched input 'PRIMARY' expecting {',', ')'}
Caused by: org.antlr.v4.runtime.InputMismatchException

主题是可用的，用模式创建，它可以从oracle数据库导入数据，流可以创建，一切都很好。但是这个表不会与我找到的所有文档相反地创建。我在这里错过了什么？

我使用的是Confluent 5.5.1，构建自tarball，ksql 0.11.0，构建自confluentinc的docker图像。

架构：

{
"subject": "g-key",
"version": 1,
"id": 1,
"schema": "{"type":"record","name":"ConnectDefault","namespace":"io.confluent.connect.avro","fields":[{"name":"ID","type":"string"}]}"
}

{
"subject": "g-value",
"version": 1,
"id": 6,
"schema": "{"type":"record","name":"ConnectDefault","namespace":"io.confluent.connect.avro","fields":[{"name":"GT_ID","type":{"type":"int","connect.type":"int8"}},{"name":"BARCODE","type":["null","string"],"default":null},{"name":"LP_ID","type":["null","long"],"default":null},{"name":"IN_G_ID","type":["null","long"],"default":null},{"name":"RS","type":"string"},{"name":"NSP","type":"string"},{"name":"EINT","type":"string"},{"name":"EINDATE","type":{"type":"long","connect.version":1,"connect.name":"org.apache.kafka.connect.data.Timestamp","logicalType":"timestamp-millis"}},{"name":"MKZ","type":"string"},{"name":"AKM","type":"int"},{"name":"AKT","type":"int"},{"name":"LZTB","type":{"type":"long","connect.version":1,"connect.name":"org.apache.kafka.connect.data.Timestamp","logicalType":"timestamp-millis"}},{"name":"TE","type":"string"},{"name":"QU","type":"string"},{"name":"ZWIZ","type":"string"},{"name":"ENDL","type":"string"},{"name":"FREIP","type":"string"},{"name":"HRLZ","type":"string"},{"name":"PERFZ","type":"string"},{"name":"EINLO","type":["null",{"type":"long","connect.version":1,"connect.name":"org.apache.kafka.connect.data.Timestamp","logicalType":"timestamp-millis"}],"default":null},{"name":"UMKJN","type":"string"},{"name":"KOLR","type":["null","int"],"default":null},{"name":"LA_ID","type":["null","long"],"default":null},{"name":"VIEW_B","type":["null","string"],"default":null}]}"
}

欢迎任何提示！

Answer 1

CP的当前版本是5.5.1，正如文档所示，它具有kqslDB v0.7.1但是"PRIMARY KEY"语法从ksqlDB v0.10 开始可用