kafka连接错误:无法找到或加载主类

6yt4nkrj  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(440)

我按照官方文件执行 kakf-connect 从文件中读取数据。
我让Kafka跑得很好。发送和接收信息的生产者和消费者。
但是,当我运行以下命令时:

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

我得到以下错误:
错误:找不到或加载主类org.apache.kafka.connect.cli.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

少了什么吗?我应该怎么做才能消除这个错误?

sqxo8psd

sqxo8psd1#

因此,相当无知的java,我认为问题是Kafka连接不包括在Kafka提供的tarball。
我转而使用confluent平台,而connect使用tarball非常有效:
http://www.confluent.io/developer#download

相关问题