我正在尝试一个简单的快速入门示例,我得到:
原因:org.apache.kafka.connect.errors.connectexception:找不到任何实现连接器且名称与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.tools.mocksourceconnector、io.confluent.connect.hdfs.tools.schemasourceconnector
这是一个全新的虚拟机运行最新的汇合平台3.2.0安装通过debian apt包。我可以看到它肯定是在运行cp3.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目录显然不存在于安装中。
我使用的是合流平台的开源变体,但根据https://www.confluent.io/product/compare/,开源版本包括合流的amazons3connect连接器。
2条答案
按热度按时间pgvzfuti1#
这是3.2.0中的一个打包错误,在最新的合流版本(截至今天(2017年5月17日)为3.2.1)中已修复
在3.2.1版本中,s3连接器也有一个bug修复,所以最好还是使用这个版本。
5lhxktic2#
作为解决方法,您可以从下载zip或tar版本http://confluent.io
从那里你会发现
kafka-connect-s3
在etc
以及share/java
目录。