在连接到ec2示例并下载kafka和java之后,我运行了以下命令:
export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"
bin/zookeeper-server-start.sh -daemon config/zookeeper-properties
bin/kafka-server-start.sh config/server-properties
然后我尝试运行命令:
kafka-console-producer --broker-list IP:9092 --topic mytopic
上面写着
未找到命令
2条答案
按热度按时间flmtquvp1#
从kafka安装目录中试试这个
注意
bin/
在命令的开头。kxeu7u2r2#
这与Kafka本身无关。你的Kafka
bin
目录,其中所有脚本kafka-console-producer
是存储的,不包含在path变量中,这意味着如果不指定这些脚本的确切位置,操作系统将无法找到这些脚本。可以修改path变量,使其包含kafka
bin
文件夹。运行此命令:但这不会在重新启动时持续,因此您应该将此语句包含在一个启动文件中,例如
~/.bashrc
.另一种选择是,从文件系统的根目录开始,通过指定命令的绝对路径来运行该命令。
或者你可以简单地
cd
进入bin
文件夹并从那里运行它。