无法找到或加载主类 org.apache.kafka.connect.cli.ConnectStandalone 当我尝试在 kafka 中运行 connect-standalone 时出现此错误。
首先我意识到这个文件所在的 libexec 中没有连接文件夹，我下载了它。还是同样的错误。
所以我尝试单独编译 ConnectStandalone.java 文件，发现我的 kafka 文件夹中缺少很多包。org/apache/kafka 中应该有一些包含一些包的 connect 和 common 文件夹，但没有。org.slf4j 包也丢失了。
我尝试手动下载一些，但如果有人能告诉我在哪里可以获得正确的文件夹。
我要做的就是创建一个简单的 kafka 生产者，它读取 csv 并将其逐行发送给消费者。
请告诉我我是否至少朝着正确的方向前进。
编辑：如果相关的话，我使用 brew 下载 kafka。
似乎 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。