gpt4 book ai didi

apache-kafka - kafka为什么不创建主题? bootstrap-server不是公认的选项

转载 作者:行者123 更新时间:2023-12-03 14:44:23 27 4
gpt4 key购买 nike

我是Kafka的新手,正在尝试在本地计算机上创建一个新主题。

我正在关注this link

这是我遵循的步骤:

  • 启动Zookeeper
    bin/zookeeper-server-start.sh config/zookeeper.properties
  • 启动kafka服务器
    bin/kafka-server-start.sh config/server.properties
  • 创建主题
    bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

  • 但是在创建主题时,出现以下错误:
    Exception in thread "main" joptsimple.UnrecognizedOptionException: bootstrap-server 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:358)
    at kafka.admin.TopicCommand$.main(TopicCommand.scala:44)
    at kafka.admin.TopicCommand.main(TopicCommand.scala)

    创建主题是否需要其他配置?
    我在做什么错

    最佳答案

    如果您使用的版本低于2.2,则应使用--zookeeper选项并将连接字符串传递给zookeeper

    命令将是这样的:
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    关于apache-kafka - kafka为什么不创建主题? bootstrap-server不是公认的选项,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55494988/

    27 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com