Не могу создать коннектор в ksqlDB - PullRequest
Новая
       3

Не могу создать коннектор в ksqlDB

0 голосов
/ 10 января 2020

Я использую ksqlDB версии 5.3.2! Когда я пытаюсь выполнить этот запрос в k sql 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

Я не знаю, мой текущий k sql поддерживает CREATE SOURCE | СОЕДИНИТЕЛЯ РАКОВИНЫ или нет! Как создать соединитель источника / приемника для интеграции с Kafka Connect? Заранее спасибо! Для получения дополнительной информации: https://ksqldb.io/examples.html#integrating с внешними источниками и приемниками данных

1 Ответ

0 голосов
/ 10 января 2020

CREATE … CONNECTOR был добавлен в ksqlDB 0.6 и будет частью Confluent Platform / K SQL 5.4.

Confluent Platform 5.4 будет выпущен в ближайшее время, или вы можете получить ksqlDB 0.6 как Docker изображение, как показано в быстром запуске .

...