如何增加或减少kafka的Partition数量?

怎么操作可以增加一个topic的partition的数量呢,或者减少?
已邀请:

空心菜 - 心向阳光,茁壮成长

赞同来自: Ansible

增加很简单,比如你之前test topic的partion为8,你现在要改成10,操作如下:
bin/kafka-topics.sh --zookeeper zook1:2181,zook2:2181,zook3:2181 --alter --topic test --partitions 10
减少目前kakfa应该是不支持的,官方是这样说的:
 Kafka does not currently support reducing the number of partitions for a topic. 
但是不知道最新版本的kafka支不支持。

要回复问题请先登录注册