kafka启动创建topic报错:zookeeper is not a recognized option

这篇具有很好参考价值的文章主要介绍了kafka启动创建topic报错:zookeeper is not a recognized option。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

当前使用版本:kafka_2.13-3.4.0

使用老版本的创建topic的命令,是用zookeeper来创建,但是报错如下

 D:\Software\Doument\kafka_2.13-3.4.0> .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test


Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
        at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
        at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
        at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
        at joptsimple.OptionParser.parse(OptionParser.java:396)
        at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:567)
        at kafka.admin.TopicCommand$.main(TopicCommand.scala:47)
        at kafka.admin.TopicCommand.main(TopicCommand.scala)


这是新版本创建topic的命令,localhost:9092是kafka的 启动地址:端口

D:\Software\Doument\kafka_2.13-3.4.0> .\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

Created topic test.

这样问题就解决了文章来源地址https://www.toymoban.com/news/detail-732111.html

到了这里,关于kafka启动创建topic报错:zookeeper is not a recognized option的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 运行kafka控制台报错:Topic XXX not present in metadata after 60000 ms.解决

    kafka消息队列项目运行后报org.springframework.kafka.KafkaException: Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic XXX not present in metadata after 60000 ms.错误, 可以尝试找到kafka的server.properties文件,进入记事本模式编辑,如果kafka配置参数设置了分区数为1( num.partitions=1 )

    2024年02月11日
    浏览(48)
  • 测试开发真的不难(8)启动Zookeeper报错ZooKeeper audit is disabled【已解决】

    今天在启动Kakfa+Zookeeper时遇见了报错:ZooKeeper audit is disabled 3.6版本以上 看了看网上的解决方案多数是针对3.6版本以上的,具体方法就是修改zookeeper的配置文件(以下图片来自网络): 找到conf文件夹下的zoo.cfg文件,对其进行修改,在里面加上admin.enable=true即可。 3.6版本以下

    2024年02月13日
    浏览(46)
  • zookeeper启动失败(Error contacting service. It is probably not running.)

    问题描述 启动zk时报如下错误: 解决办法 先查日志找找报错原因: 找到zk安装目录下的logs文件夹下的日志文件,查看连接失败原因: 如果是端口问题,修改conf文件,指定端口重新启动即可: 注:3.5以后的版本, 会自动占用8080端口. 需要修改配置文件。

    2024年02月10日
    浏览(44)
  • zookeeper搭建分布式集群启动失败(Error contacting service. It is probably not running.)

    1.启动zookeeper后查看状态 /bin/zkServer.sh status 发现报错 Error contacting service. It is probably not running. 2.查看日志 zookeeper-root-server-zookeeper01.out 发现报了一拒绝链接java.net.ConnectException: 拒绝连接 (Connection refused) 方法1: 将配置文件 zoo.cfg 中节点对应机器的地址改为:0.0.0.0 修改完再此

    2024年02月06日
    浏览(62)
  • 在Windows上搭建Kafka环境的步骤,包括安装Java、下载Kafka、配置Zookeeper和Kafka、启动Zookeeper和Kafka、创建主题和生产者/消费者等

    1. 安装Java Kafka需要Java环境支持。可以从Oracle官网下载JDK,或者使用OpenJDK。 2. 下载Kafka 可以从Kafka官网下载Kafka二进制压缩包。解压后可以看到bin、config、libs等目录。 3. 配置Zookeeper Kafka依赖Zookeeper实现分布式协作。可以使用Kafka自带的Zookeeper,也可以独立安装Zookeeper。 如果使

    2024年02月11日
    浏览(45)
  • Maven: ‘mvn‘ is not recognized as an internal or external command

    下载并配置好Maven之后,CMD测试安装是否成功:mvn -v 提示: \\\'mvn\\\' is not recognized as an internal or external command, operable program or batch file. 检查环境变量: MAVEN_HOME: %MAVEN_HOME%bin:    看上去没问题,怎么回事呢? 探索一番,找到了原因。是Path变量中,最后一个分号的问题,删掉分号

    2024年02月13日
    浏览(51)
  • kafka-报错-The coordinator is not aware of this member

    我在项目里把原来用着的 独立消费者 consumer-group-id 同时当做消费者组来消费分区信息,导致协调器找不到这个 consumer-group-id 注册两个测试 topic 写一个消费者组 启动项目,发送消息 报错日志 查看kafka服务器的消费者状态

    2024年02月13日
    浏览(69)
  • Angular之创建项目报错:setTimeout is not defined

    零基础的宝们,跟着视频学习Angular中,会教授大家如何创建一个新项目。 但是在操作时就会遇到无法创建的问题。 接下来我们一起来看看,本人Angular起步时卡在家门口的问题。 在已经安装了nodejs的情况下,被建议使用cnpm命令全局安装 Angular CLI cnpm install -g @angular/cli 它是这

    2024年02月16日
    浏览(35)
  • 当zookeeper报错Invalid config, exiting abnormally,Error contacting service. It is probably not running

    配置版本 zookeeper-3.4.6 hadoop-2.7.7 jdk1.8/jdk8 centos7 当你启动zookeeper报错可以先试以下方法  或者Error contacting service. It is probably not running server.~master:2888:3888 server前后是否有空格(复制容易犯这个错误) 一种是该文提到的(详情可点击该链接)(17条消息) 成功解决ZooKeeper配置中出现Err

    2024年02月06日
    浏览(57)
  • 【Kafka】ZooKeeper启动失败报错java.net.BindException: Address already in use: bind

    Kafka 2.8.1 ZooKeeper启动失败。 2181端口被占用。 打开cmd。 无结果返回,找不到占用2181端口的程序。 修改config/zookeeper.properties 找到: 改为: 重新启动ZooKeeper,启动成功。 记得修改config/server.properties,不然Kafka Server无法连接。 找到: 改为: 在解决端口被占用的问题时,首先需

    2024年02月09日
    浏览(64)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包