基于0.8.0版本。
##查看topic分布情况kafka-list-topic.sh
##创建TOPIC kafka-create-topic.sh
bin/kafka-create-topic.sh --replica
2 --partition 8 --topic test --zookeeper 192.168.197.170:2181,192.168.197.171:2181
创建名为test的topic, 8个分区分别存放数据,数据备份总共2份
1 --partition 1 --topic test2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181
##重新分配分区kafka-reassign-partitions.sh
--topics-to-move-json-file topics-to-move.json --broker-list "171"
--zookeeper 192.168.197.170:2181,192.168.197.171:2181 --execute
##为Topic增加 partition数目kafka-add-partitions.sh
(为topic test增加2个分区)
##控制台接收消息
bin/kafka-console-consumer.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --from-beginning
--topic test
##控制台发送消息
bin/kafka-console-producer.sh --broker-list 192.168.197.170:9092,192.168.197.171: 9092 --topic
test
##手动均衡topic, kafka-preferred-replica-election.sh
bin/kafka-preferred-replica-election.sh
192.168.197.170:2181,192.168.197.171:2181
--zookeeper --path-to-json-file preferred-click.json
cat preferred-click.json
{
"partitions":
[
{"topic": "click", "partition": 0},
{"topic": "click", "partition": 1},
{"topic": "click", "partition": 2},
{"topic": "click", "partition": 3},
{"topic": "click", "partition": 4},
{"topic": "click", "partition": 5},
{"topic": "click", "partition": 6},
{"topic": "click", "partition": 7},
{"topic": "play", "partition": 0},
{"topic": "play", "partition": 1},
{"topic": "play", "partition": 2},
{"topic": "play", "partition": 3},
{"topic": "play", "partition": 4},
{"topic": "play", "partition": 5},
{"topic": "play", "partition": 6},
{"topic": "play", "partition": 7}
]
}