【问题标题】:kafka-connect error: cannot find or load main classkafka-connect 错误:找不到或加载主类
【发布时间】: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


【解决方案1】:

所以我对 java 很无知,我认为问题在于 kafka-connect 不包含在 kafka 提供的 tarball 中。

我改为使用 confluent 平台,并且使用该 tarball 连接效果很好:

http://www.confluent.io/developer#download

【讨论】:

  • 对不起,但这对我来说并不是一个真正的解决方案,因为我需要使用本机 apache kafka 有很多原因。我只需要这个版本的解决方法。 Kafka connect 已经包含在 kafka 的压缩包中。
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2016-08-27
  • 2014-03-28
  • 2014-11-18
  • 1970-01-01
  • 2019-02-06
  • 2013-01-17
相关资源
最近更新 更多