kafka控制台生产者:未找到命令

cqoc49vn  于 2021-06-06  发布在  Kafka
关注(0)|答案(2)|浏览(607)

在连接到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

上面写着
未找到命令

flmtquvp

flmtquvp1#

从kafka安装目录中试试这个

bin/kafka-console-producer --broker-list IP:9092 --topic mytopic

注意 bin/ 在命令的开头。

kxeu7u2r

kxeu7u2r2#

这与Kafka本身无关。你的Kafka bin 目录,其中所有脚本 kafka-console-producer 是存储的,不包含在path变量中,这意味着如果不指定这些脚本的确切位置,操作系统将无法找到这些脚本。
可以修改path变量,使其包含kafka bin 文件夹。运行此命令:

export PATH="${PATH}:/path-to-bin-dir/bin"

但这不会在重新启动时持续,因此您应该将此语句包含在一个启动文件中,例如 ~/.bashrc .
另一种选择是,从文件系统的根目录开始,通过指定命令的绝对路径来运行该命令。

/path-to-bin-dir/bin/kafka-console-producer --broker-list IP:9092 --topic mytopic

或者你可以简单地 cd 进入 bin 文件夹并从那里运行它。

./kafka-console-producer --broker-list IP:9092 --topic mytopic

相关问题