无法在 ksqlDB 中创建连接器

Question

我正在使用 ksqlDB 5.3.2 版！当我尝试在 ksql CLI 中执行此查询时：

CREATE SINK CONNECTOR `hdfs_connector` WITH (
'connector.class'='io.confluent.connect.hdfs3.Hdfs3SinkConnector',
'tasks.max'='1',
'topics'='CUSTOMERS_CITY_2',
'hdfs.url'='hdfs://192.168.2.114:8020/tmp',
'flush.size'='3',
'key.converter'='org.apache.kafka.connect.storage.StringConverter',
'value.converter'='io.confluent.connect.avro.AvroConverter',
'value.converter.schema.registry.url'='http://192.168.2.113:8081',
'confluent.topic.bootstrap.servers'='192.168.2.113:9092',
'confluent.topic.replication.factor'='1');

我收到一个错误：

Caused by: line 1:8: no viable alternative at input 'CREATE SINK'
Caused by: org.antlr.v4.runtime.NoViableAltException

我不知道我当前的 ksql 是否支持 CREATE SOURCE | SINK CONNECTOR 功能与否！我如何创建 source/sink 连接器以与 Kafka Connect 集成？提前致谢！更多信息：https://ksqldb.io/examples.html#integrating-with-external-data-sources-and-sinks

Answer 1

CREATE … CONNECTOR 是在 ksqlDB 0.6 中添加的，并将成为 Confluent Platform / KSQL 5.4 的一部分。

Confluent Platform 5.4 即将发布，或者您可以获取 ksqlDB 0.6 作为 Docker 图像，如图 in the quickstart.

无法在 ksqlDB 中创建连接器

Can not create connector in ksqlDB

ksqldb