【发布时间】:2016-09-13 01:36:34
【问题描述】:
我正在关注official docs to implement 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
有什么遗漏吗?我应该怎么做才能摆脱这个错误?
【问题讨论】:
-
能否检查类路径是否设置正确?
-
@Jango 你能详细说明一下吗?如何检查?
-
connect/runtime/src/main/java/ 这应该是执行时的类路径,以便可以找到包 org 并可以加载该类。我希望这就是失败的原因。
-
@Jango 我跑了
export CLASSPATH=~/pathTo/connect/runtime/src/main/java/并再次尝试,但它不起作用。
标签: java apache-kafka kafka-consumer-api kafka-producer-api