无法找到或加载主类 org.apache.kafka.connect.cli.ConnectStandalone 当我尝试在 kafka 中运行 connect-standalone 时出现此错误。
首先我意识到这个文件所在的 libexec 中没有连接文件夹，我下载了它。还是一样的错误。
所以我尝试单独编译 ConnectStandalone.java 文件，发现我的 kafka 文件夹中缺少很多包。 org/apache/kafka 中应该有一些包含一些包的 connect 和 common 文件夹，但没有。 org.slf4j 包也丢失了。
我尝试手动下载一些，但如果有人能告诉我在哪里可以获得正确的文件夹。
我要做的就是创建一个简单的 kafka 生产者，它读取 csv 并将其逐行发送给消费者。
请告诉我我是否至少朝着正确的方向前进。
编辑：我使用 brew 下载 kafka，如果相关的话。
【问题讨论】：
标签： apache-kafka apache-kafka-connect
似乎 kafka 安装的二进制文件不完整。拥有 csv 文件的生产者消费者。您可以在 Linux 机器上运行示例事物作为示例。
假设kafka borker在localhost:9092，zookeeper在localhost:2181，打开2个控制台，去kafka home
在第一个控制台创建主题test:
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-factor 1
然后通过以下方式在该控制台中以消费者身份打开：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test
在第二个控制台发送 csv 数据到测试主题：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test < abc.csv
在第一个控制台上查看消耗的 csv 数据。
如果上述命令也没有运行，那么你需要重新安装 kafka 和 zookeeper。
【讨论】：