Kafka Confluent S3 连接器 "Failed to find class"

Question

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

Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.s3.S3SinkConnector, available connectors are: 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 连接器 class 不可用？

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

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 Platform 的开源变体，但根据 https://www.confluent.io/product/compare/，开源版本包括 Confluent Amazon S3 Connect 连接器。

Answer 1

作为解决方法，您可以从 http://confluent.io

下载 zip 或 tar 版本

从那里您会在 etc 和 share/java 目录中找到 kafka-connect-s3。

Answer 2

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

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

Kafka Confluent S3 连接器 "Failed to find class"

Kafka Confluent S3 Connector "Failed to find class"

amazon-s3

apache-kafka

apache-kafka-connect

confluent-platform