kafka-connect错误:无法找到或加载主类

我正在遵循官方文档来实现 kakf-connect以从文件中读取数据。

我有完美的kafka跑步。 生产者和消费者发送和接收消息。

但是,当我运行以下命令时:

 sudo ./bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties 

我收到以下错误:

错误:无法找到或加载主类org.apache.kafka.connect.cli.ConnectStandalone

我交叉检查,我有ConnectStandalone文件connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone

我的connect-file-source.properties如下:

 name=local-file-source connector.class=org.apache.kafka.connect.file.FileStreamSourceConnector tasks.max=1 file=test.txt topic=spark-kafka 

有什么遗失的吗? 我该怎么做才能摆脱这个错误?

因此,相当java无知我认为问题是kafka-connect不包含在kafka提供的tarball中。

我转而使用汇合平台,并使用该tarball进行连接工作:

http://www.confluent.io/developer#download