刚刚安装了spotify/kafka的docker图像。sudo docker ps:
82c411a52a38 spotify/kafka "supervisord -n" 26 minutes ago Up 26 minutes 0.0.0.0:2181->2181/tcp, 0.0.0.0:9092->9092/tcp
另外,还分别下载了kafka二进制文件,因此我可以使用kafka-console-producer.sh测试安装,如下所示: https://hub.docker.com/r/spotify/kafka/
我设置了以下环境变量:
Kafka=事件-dev:9092 zookeeper=event-ora-dev:2181
当我运行命令时 ./kafka-console-producer.sh --broker-list $KAFKA --topic test
我得到这个错误:
Error: Could not find or load main class kafka.tools.ConsoleProducer
假设kafka.tools.consoleproducer是一个java类,由kafka-console-producer.sh shell脚本调用-我应该在哪里查找这个java类?
2条答案
按热度按时间tkqqtvp11#
我用Kafka10也有同样的问题:比如@matthiasj。sax说我丢失了一些jar,所以我发现当下载kafka琰u2.10-0.10.2.1时,我在lib中丢失了jar,当我下载kafka琰u2.12-0.10.2.1时,我得到了完整的lib文件夹。
我的底线是:
wget公司http://www-us.apache.org/dist/kafka/0.10.2.1/kafka_2.12-0.10.2.1.tgz
tar-xvfKafka2.12-0.10.2.1.tgz
./kafka_2.12-0.10.2.1/bin/kafka-console-producer.sh--代理列表$kafka--主题测试
nbnkbykc2#
如果您从项目网站下载Kafka并将其解压缩,则会有一个子文件夹
lib
包含所有jar
文件夹。kafka-console-producer.sh
将需要kafka-tools-0.9.0.1.jar
为了kafka.tools.ConsoleProducer
(或者不同的版本--不确定您使用的是什么)。如果你跑了
bin/kafka-console-producer.sh
从顶层文件夹,这应该是现成的。