java - 在 Apache Kafka 中创建主题时出错

Question

使用命令时:

/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

我收到以下错误:

Unrecognized option: --create
Error: Could not create the Java Virtual Machine
Error: A fatal exception has occurred. Program will exit.

我正在按照 Kafka:权威指南一书中的说明进行操作。

提前致谢。

Answer 1

我遇到了和你一样的问题。我能够通过在脚本中添加 sudo 使其工作:/usr/local/kafka/bin/kafka-topics.sh

exec sudo $(dirname $0)/kafka-run-class.sh kafka.admin.TopicCommand "$@"