方法一 : 重启kafka
网上找的 大部分说法都是重启kafka , 从参数设置默认分区 .
./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --partitions 12 --topic test
方法二: 只修改topic的
如果有安装kafka manager . 那么 kafka manager 上可以操作修改指定topic的.


修改是即时生效的 .
网上找的 大部分说法都是重启kafka , 从参数设置默认分区 .
./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --partitions 12 --topic test
如果有安装kafka manager . 那么 kafka manager 上可以操作修改指定topic的.
修改是即时生效的 .
本文标题:Invalid partition given with rec
本文链接:https://www.haomeiwen.com/subject/xfpcartx.html
网友评论