我在增加topic分区时报错 The broker does not support CREATE_PARTITIONS，这该怎么解决？

*. 发表于: 2022-03-04   最后更新时间: 2022-03-04 14:42:43   2,506 游览 
[atguigu@hadoop102 kafka]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --topic first --partitions 3

Error while executing topic command : The broker does not support CREATE_PARTITIONS
[2022-03-04 13:53:46,988] ERROR org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support CREATE_PARTITIONS
 (kafka.admin.TopicCommand$)
[atguigu@hadoop102 kafka]$ kafka-topics.sh --version
3.0.0 (Commit:8cb0a5e9d3441962)
kafka
发表于 2022-03-04
*.
  • 补充一下你kafka集群的规模，最好describe一下。半兽人 2年前
    @半兽人 [atguigu@hadoop102 zkData]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first Topic: first PartitionCount: 1 ReplicationFactor: 3 Configs: segment.bytes=1073741824 Topic: first Partition: 0 Leader: 1 Replicas: 1,0,2 Isr: 1,2*.
    @半兽人 我用的虚拟机，虚拟了三台服务器分别为hadoop102,hadoop103,hadoop104 kafka集群就是用的这三台服务器。*.
￥1.0

目前我想到的只有一种可能，你命令行调用到了别的kafka集群，版本不同导致的这个错误。

回复
回答于 2年前
半兽人
*. -> 半兽人 2年前

我之前安装了旧版本的kafka，然后我删了旧版的安装目录重新安装新版本的kafka了。
还有就是topic现在我也删不掉了，报错说timeout

0 0 回复
*. -> 半兽人 2年前

server.log的内容：

ERROR Closing socket for 192.168.10.103:9092-192.168.10.102:47940 because of error (kafka.network.Processor)
org.apache.kafka.common.errors.InvalidRequestException: Error getting request for apiKey: 1 and apiVersion: 12
Caused by: java.lang.IllegalArgumentException: Invalid version for API key FETCH: 12
0 0 回复
半兽人 -> *. 2年前

清理干净吧环境，八九不离十。

另外，你看看解析的地址对不对

ping hadoop102
0 0 回复
*. -> 半兽人 2年前 
PING hadoop102 (192.168.10.102) 56(84) bytes of data.
64 bytes from hadoop102 (192.168.10.102): icmp_seq=1 ttl=64 time=1.05 ms
64 bytes from hadoop102 (192.168.10.102): icmp_seq=2 ttl=64 time=2.13 ms
0 0 回复
*. -> 半兽人 2年前

我彻底重装了，然后可以了，谢谢大佬。

0 0 回复
*. -> 半兽人 2年前

我彻底重装了，然后可以了，谢谢大佬。

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。