4

我正在尝试一个简单的快速入门示例，我得到：

原因：org.apache.kafka.connect.errors.ConnectException：找不到任何实现Connector且名称与io.confluent.connect.s3.S3SinkConnector匹配的类，可用的连接器有：io.confluent.connect.jdbc.JdbcSinkConnector , io.confluent.connect.jdbc.JdbcSourceConnector, org.apache.kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apache.kafka.connect.sink.SinkConnector, io.confluent .connect.elasticsearch.ElasticsearchSinkConnector、org.apache.kafka.connect.tools.MockConnector、io.confluent.connect.hdfs.HdfsSinkConnector、org.apache.kafka.connect.file.FileStreamSinkConnector、org.apache.kafka.connect.tools .VerifiableSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.SchemaSourceConnector, org.apache.kafka.connect.source.SourceConnector、org.apache.kafka.connect.tools.MockSourceConnector、io.confluent.connect.hdfs.tools.SchemaSourceConnector

这是一个全新的 VM，运行通过 Debian apt 包安装的最新 Confluent Platform 3.2.0。我可以看到它肯定在运行 CP 3.2.0。为什么 S3 连接器类不可用？

不确定这是否相关，但如果我这样做：

ls -l /etc/ | grep kafka
drwxr-xr-x 2 root root           4096 Apr  5 04:41 kafka
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-connect-elasticsearch
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-connect-hdfs
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-connect-jdbc
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-rest

文档引用了安装中显然不存在的 kafka-connect-s3 目录。

我正在使用 Confluent 平台的开源变体，但根据https://www.confluent.io/product/compare/，开源版本包括 Confluent Amazon S3 Connect 连接器。

4

2 回答 2

1

作为一种解决方法，您可以从http://confluent.io下载 zip 或 tar 版本

从那里你会kafka-connect-s3在etcandshare/java目录中找到。

于 2017-05-18T02:57:07.073 回答
1

这是 3.2.0 中的一个打包错误，并在最新的 Confluent 版本中得到修复，截至今天（2017 年 5 月 17 日）为 3.2.1

在 3.2.1 版本中还修复了 S3 连接器的错误，因此最好还是使用该版本。

于 2017-05-18T04:25:08.660 回答