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

*. 发表于: 2022-03-04   最后更新时间: 2022-03-04 14:42:43   300 游览
[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)
发表于 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月前

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

*. -> 半兽人 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
半兽人 -> *. 2月前

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

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

ping hadoop102
*. -> 半兽人 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
*. -> 半兽人 2月前

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

*. -> 半兽人 2月前

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

你的答案

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