KSQLDB连接拒绝Kafka连接

Question

我正在KSQLDB弹性搜索连接器上执行PoC。

以下是网上两份文件：

第一：

https://ksqldb.io/quickstart.html

在我放假之后，一切都很好

第二项：

https://github.com/confluentinc/demo-scene/blob/master/build-a-streaming-pipeline/demo_build-a-streaming-pipeline.adoc

当我运行这个命令时，我得到了这个问题：

CREATE SINK CONNECTOR SINK_ES_sample_1 WITH (
    'connector.class' = 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector',
    'topics'          = 'sample_1',
    'connection.url'  = 'http://localhost:9200',
    'type.name'       = '_doc',
    'key.ignore'      = 'false',
    'schema.ignore'   = 'true',
    'transforms'= 'ExtractTimestamp',
    'transforms.ExtractTimestamp.type'= 'org.apache.kafka.connect.transforms.InsertField$Value',
    'transforms.ExtractTimestamp.timestamp.field' = 'sample_1'
);

错误：

org.apache.hc.client5.http.HttpHostConnectException:连接到http://localhost:8083 localhost/127.0.0.1失败:连接拒绝(连接拒绝)由: org.apache.hc.client5.http.HttpHostConnectException:连接到http://localhost:8083本地主机/127.0.0.1失败:连接拒绝(连接拒绝)由:无法连接到服务器。请检查服务器详细信息是否正确，服务器是否正在运行。

Answer 1

这表明您在ksqlDB服务器与Kafka的连接中配置了错误。

如果您正在跟踪那个演示脚本，那么您应该使用关联的Docker组合文件，即正确配置

      KSQL_KSQL_CONNECT_URL: http://kafka-connect-01:8083