ksqldb - 无法在 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 功能与否！如何创建源/接收器连接器以与 Kafka Connect 集成？提前致谢！欲了解更多信息：https ://ksqldb.io/examples.html#integrating-with-external-data-sources-and-sinks

标签： ksqldb

Answer 1

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

Confluent Platform 5.4 即将发布，或者您可以将 ksqlDB 0.6 作为 Docker 映像获取，如快速入门中所示。