kafka连接器-入门-找不到或加载主类org.apache.kafka.connect.cli.ConnectStandalone

Question

嗨，我正在学习一个教程(不确定我是否可以在这里发布链接)来学习kafka连接。

我下载了合流-6.2.0

我运行这个命令

bin/connect-standalone etc/kafka/connect-standalone.properties

并得到以下消息

could not find or load main class org.apache.kafka.connect.cli.ConnectStandalone

我打印出它的类路径

$DIR/share/java/confluent-security/connect/*:$DIR/share/java/kafka/*:$DIR/share/java/confluent-common/*:$DIR//share/java/kafka-serde-tools/*:$DIR/share/java/monitoring-interception/*

我已经检查了ConnectStandalone在$DIR/share/java/kafka/connect-runtime-6.2.0-ce.jar中的类

想知道我错过了什么吗？

$DIR是汇流的根目录。

这是我的etc/kafka/connect-standalone.properties文件中的插件路径

plugin.path=/d/developer/confluent/confluent-6.2.1/share/java

这是目录的内容。

λ ls /d/developer/confluent/confluent-6.2.1/share/java

acl/                       confluent-hub-client/        kafka/                     monitoring-interceptors/
ce-kafka-http-server/      confluent-kafka-mqtt/        kafka-connect-replicator/  rest-utils/
ce-kafka-rest-extensions/  confluent-metadata-service/  kafka-rest-bin/            schema-registry/
ce-kafka-rest-servlet/     confluent-rebalancer/        kafka-rest-lib/
confluent-common/          confluent-security/          kafka-serde-tools/
confluent-control-center/  confluent-telemetry/         ksqldb/

Answer 1

我有一个Kafka-kenises应用程序的docker容器，然后调用以下类。

<stringAttribute key="org.eclipse.jdt.launching.MAIN_TYPE" value="org.apache.kafka.connect.cli.ConnectStandalone"/>

虽然我的错误如下，我是新手对接，卡夫卡和动感，知道这个错误是什么，如何解决它？

 task.shutdown.graceful.timeout.ms = 5000
10
  value.converter = class org.apache.kafka.connect.storage.StringConverter
9
 (org.apache.kafka.connect.runtime.standalone.StandaloneConfig)
8
[2022-10-10 17:41:33,984] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectStandalone)
7
java.lang.NoClassDefFoundError: org/apache/kafka/common/record/InvalidRecordException
6
  at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:81)
5
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.record.InvalidRecordException
4
  at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:582)
3
  at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:185)
2
  at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:496)