我正在尝试使用apachekafka执行一个示例producer-consumer应用程序。我从网上下载的https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz。然后我开始按照http://www.javaworld.com/article/3060078/big-data/big-data-messaging-with-kafka-part-1.html.
当我试图运行bin/zookeeper-server-start.sh config/zookeeper.properties时，出现了一个错误：找不到或无法加载主类config.zookeeper.properties我在google中搜索了这个问题，但没有得到任何有用的信息。有人能帮我继续吗？
3条答案
按热度按时间ajsxfq5m1#
您已下载源程序包。下载kafka的二进制软件包并进行测试。
vfwfrxfs2#
假设您有正确的二进制版本检查，以确定您的环境中尚未定义类路径。如果这样做并且定义的类路径中有一个空格（例如c:\program files<>），那么zookeeper和kafka都不会启动。
要解决这个问题，可以删除现有的类路径，或者修改构建zookeeper和kafka类路径值的启动脚本，在构建路径之前将类路径条目放在双引号中
r8xiu3jd3#
你必须从Kafka官方网站下载二进制版本。