1、创建 topic
/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper zoo1:2181,zoo2:2181,zoo3:2181 --replication-factor 3 --partitions 3 --topic kafka_test
--topic 名字
--replication-factor 副本数
--partitions 分区数
2、列出所有的topic
/usr/local/kafka/bin/kafka-topics.sh --list --zookeeper zoo1:2181,zoo2:2181,zoo3:2181
3、查看topic
/usr/local/kafka/bin/kafka-topics.sh --zookeeper zoo1:2181,zoo2:2181,zoo3:2181 --topic topicTest --describe
4、删除topic
/usr/local/kafka/bin/kafka-topics.sh --delete --zookeeper zoo1:2181,zoo2:2181,zoo3:2181 --topic kafka_test 标记为marked for deletion
此时你若想真正删除它，可以如下操作：
（1）登录zookeeper客户端：命令：./bin/zookeeper-client
（2）找到topic所在的目录：ls /brokers/topics
（3）找到要删除的topic，执行命令：rmr /brokers/topics/【topic name】即可，此时topic被彻底删除。
另外被标记为marked for deletion的topic你可以在zookeeper客户端中通过命令获得：ls /admin/delete_topics/【topic name】，
如果你删除了此处的topic，那么marked for deletion 标记消失
5、发送信息
/usr/local/kafka/bin/kafka-console-producer.sh --broker-list kafka1:9092 --topic kafka_test
>hello
>welcome
6、消费消息（新版本kafka使用）
/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka2:9092 --topic kafka_test --from-beginning
问题1:
重启一个kafka后，集群不能自动平衡，执行手动平衡。
/usr/local/kafka/bin/kafka-preferred-replica-election.sh --zookeeper zoo1:2181