在kafka部署完成后，后面还会遇到配置参数调整一系列的调试，关于配置调整方面，kafka做的确实不太友好，

1 创建topics

    kafka-topics.sh --zookeeper zk_host:port/chroot --create --topic my_topic_name --partitions 20 --replication-factor 3 --config x=y

    kafka-topics.sh --zookeeper zk_host:port/chroot --alter --topic my_topic_name --partitions 40

     kafka-topics.sh --zookeeper zk_host:port/chroot --alter --topic my_topic_name --config x=y

     删除配置

     kafka-topics.sh --zookeeper zk_host:port/chroot --alter --topic my_topic_name --deleteConfig x

     删除topic

     kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name 该功能还是beta在0.8.1中

    目前kafka还不支持给topic减少partitions和replication

3 停止kafka

  优雅的停止kafka有两个好处：

  1 它会sync它的log到磁盘上，避免下次重启时需要修复log

    kafka-preferred-replica-election.sh --zookeeper zk_host:port/chroot

    kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group test

7 扩展你的集群

    加入集群是很容易的，只要分配一个唯一的broker id，然后启动kafka进程即可，但是这样并不会自动的分配数据partitions，除非把partitions移动到新的kafka节点上面，或者新建的topics可能把数据partitions分配在新的kafka节点上面，当你把新节点加入集群的时候，你可能会想移动一些存在的数据到该机器上。但这个过程需要手动完成，有三种模式可选：

--generate: In this mode, given a list of topics and a list of brokers, the tool generates a candidate reassignment to move all partitions of the specified topics to the new brokers. This option merely provides a convenient way to generate a partition reassignment plan given a list of topics and target brokers.

--execute: In this mode, the tool kicks off the reassignment of partitions based on the user provided reassignment plan. (using the --reassignment-json-file option). This can either be a custom reassignment plan hand crafted by the admin or provided by using the --generate option

--verify: In this mode, the tool verifies the status of the reassignment for all partitions listed during the last --execute. The status can be either of successfully completed, failed or in progress

     1 编写扩容文件topics-to-move.json

{"topics": [{"topic": "foo1"},            {"topic": "foo2"}], "version":1 }

     2 生成数据迁移配置

         kafka-reassign-partitions.sh --zookeeper localhost:2181 --topics-to-move-json-file topics-to-move.json --broker-list "5,6" --generate

     3 执行迁移

         kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file expand-cluster-reassignment.json --execute

     4 查询执行的状态

         kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file expand-cluster-reassignment.json --verify

  8  自定义分区的分配和迁移

     topic foo1 partition0 -->brokers 5 6

     {"version":1,"partitions":[{"topic":"foo1","partition":0,"replicas":[5,6]},{"topic":"foo2","partition":1,"replicas":[2,3]}]}

     kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file custom-reassignment.json --execute

     3 检查

     kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file custom-reassignment.json --verify

下面介绍两个好工具：

kafka-manage