Kafka 连接独立 - 无法找到或加载主 class org.apache.kafka.connect.cli.ConnectStandalone

Question

无法找到或加载主程序 class org.apache.kafka.connect.cli.ConnectStandalone 当我尝试 运行 connect-standalone in kafka 时出现此错误。

首先我意识到这个文件所在的 libexec 中没有连接文件夹，我下载了那个。还是一样的错误。

所以我尝试单独编译ConnectStandalone.java文件，发现我的kafka文件夹里少了很多包。 org/apache/kafka 中应该有一些包的连接和公共文件夹，但没有。 包 org.slf4j 也丢失了。

我试着手动下载了一些，但如果有人能告诉我在哪里可以获得正确的文件夹。

我想做的就是创建一个简单的 kafka 生产者，它读取 csv 并将其逐行发送给消费者。

请告诉我我是否至少朝着正确的方向前进。

编辑：如果相关的话，我使用 brew 下载 kafka。

Answer 1

似乎kafka 安装的二进制文件不完整。拥有 csv 文件的生产者消费者。您可以 运行 以 Linux 机器为例。

假设 kafka borker 在 localhost:9092 和 zookeeper 在 localhost:2181，打开 2 console 并转到 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 数据。

如果以上命令也没有 运行ning 那么你需要重新安装 kafka 和 zookeeper。