在 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.

我正在按照《卡夫卡：权威指南》一书中的说明进行操作。

提前致谢。

Answer 1

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

exec sudo $(dirname [=10=])/kafka-run-class.sh kafka.admin.TopicCommand "$@"

Answer 2

您应该检查您是否下载了正确的（已编译的）版本。

如果您尝试运行源代码版本中的脚本，可能会发生这种情况。

Error creating topic in Apache Kafka