【发布时间】:2016-08-27 22:18:37
【问题描述】:
刚刚安装了一个 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/
我设置了以下 ENV 变量:
KAFKA=event-ora-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 类?
【问题讨论】:
标签: apache-kafka kafka-producer-api