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

qvsjd97n 于 2022-11-01 发布在 Apache

关注(0)|答案(1)|浏览(196)

你好，我下面的教程（不确定如果我可以在这里发布链接）学习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/

apache-kafka

来源：https://stackoverflow.com/questions/69676516/kafka-connectors-getting-started-could-not-find-or-load-main-class-org-apach

1条答案

按热度按时间

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)

中的每一个

赞(0）回复(0）举报 2022-11-09

我来回答

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

1条答案

相关问题

热门标签

最新问答