java - kafka-connect 错误：找不到或加载主类

Question

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

我有卡夫卡完美运行。生产者和消费者发送和接收消息。

但是，当我运行以下命令时：

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

我收到以下错误：

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

我交叉检查，我有文件ConnectStandalone here 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

有什么遗漏吗？我应该怎么做才能摆脱这个错误？

score -1 · Accepted Answer

因此，由于对 java 非常无知，我认为问题在于 kafka-connect 不包含在 kafka 提供的 tarball 中。

我转而使用 confluent 平台，并且使用该 tarball 连接效果很好：

1 回答 1