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

qvsjd97n  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(195)

你好,我下面的教程(不确定如果我可以在这里发布链接)学习Kafka连接
我已经下载了confluent-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是confluent的根目录
这是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/
xxls0lw8

xxls0lw81#

我 有 一 个 用于 Kafka-kenises 应用 程序 的 Docker 容器 , 该 应用 程序 依次 调用 以下 类
x1月 1 日
虽然 我 得到 了 如下 错误 , 我 是 新手 码头 , Kafka 和 Kinesis , 任何 想法 是 什么 这个 错误 和 如何 修复 它 ?

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)

中 的 每 一 个

相关问题