我正在关注official docs to implement kakf-connect
从文件中读取数据。
我的卡夫卡运行得很好。发送和接收消息的生产者和消费者。
但是,当我运行以下命令时:
sudo ./bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties
我收到以下错误:
Error: Could not find or load main class 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 连接效果很好:
关于java - kafka连接错误: cannot find or load main class,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35179108/