我正在尝试使用 Ubuntu 中的以下命令运行程序来连接 Kafka 与 MQ,但出现以下错误
错误:
无法找到或加载主类org.apache.kafka.connect.cli.ConnectStandalone
命令:
CLASSPATH=<connector-root-directory>/target/kafka-connect-mq-sink-<version>-jar-with-dependencies.jar ./bin/connect-standalone.sh config/connect-standalone.properties ~/mq-sink.properties
您不必指定类路径。
在
config/connect-standalone.properties
文件中,您可以声明 plugin.path
属性(例如: plugin.path=/usr/local/share/java
)。然后,您必须将罐子放在该路径上。
我在 Windows 上运行 MongoDb 连接器时遇到了同样的问题。每当我运行
bin\connect-standalone.sh
时,我都会遇到同样的错误。我注意到有一个bin\windows\connect-standalone.bat
,但里面是空的。所以我复制了connect-distrubted.bat
中的内容,并将所有出现的distributed
替换为standalone
。现在运行 bat 成功启动连接器,即使在启动过程中抛出一些异常,例如could not get type for name org.easymock.IArgumentMatcher