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

标签 java apache-kafka apache-zookeeper

使用命令时:

/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:权威指南一书中的说明进行操作。

提前致谢。

最佳答案

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

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

关于java - 在 Apache Kafka 中创建主题时出错,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42535560/

相关文章:

elasticsearch - 为了将日志数据获取到我的业务逻辑(在 Spark 中定义),在 Logstash 和 Spark Streaming 之间使用 Apache Kafka 是否正确?

apache - 启动Zookeeper集群。错误:找不到或加载主类org.apache.zookeeper.server.quorum.QuorumPeerMain

java - 无法运行HBase的示例-权威指南

java - countTokens() 在用户输入时总是返回 1

使用笔自由绘制时,JavaFX 在 Canvas 上的性能下降

java - 立即从 Java 8 流的集合中返回一个值

java - spring-cloud-starter-stream-kafka 不会创建提供给 spring.boot.cloud.stream.bindings.output.destination 的主题

java - 是否有任何基于文件的数据库,具有类似于 MS Access 但开源的并发每个文件用户 Access 权限?

apache-kafka - 用于时间序列数据持久性的 Apache Kafka

docker - 在同一台机器的两个docker conatiners中创建kafka代理和zookeeper的利弊是什么