kafka如何修改topic的分区数

THEYUNG 发表于: 2020-12-21   最后更新时间: 2020-12-21  

通过命令修改后重启,分区数又变回1

kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic --partitions 3


您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: springboot整合kafka bootstrap-servers设置多个ip
下一条: 1. Kafka普通消费和顺序消费的区别?以及应用场景? 2. producer和consumer分别什么时候需要用group?相比不用有哪些优势? 3. broker的应用场景?相比不用有哪些优势?

  • 试试这个:

    bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic my_topic_name --partitions 40
    
    • 报了这个错

      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.(TopicCommand.scala:358)
          at kafka.admin.TopicCommand$.main(TopicCommand.scala:44)
          at kafka.admin.TopicCommand.main(TopicCommand.scala)
      
        • 你的kafka版本<2.2,不识别bootstrap-server,正确方式和日志

          bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --partitions 3
          WARNING: If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected
          Adding partitions succeeded!
          

          查看是否增加成功:

          bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic1