二、kafka常用命令
1、启动
kafka ./startkafka.sh（bin/kafka-server-start.sh config/server.properties）
2、创建kafka(node3、node4、node5是kafka的安装地址)
./bin/kafka-topics.sh --create --zookeeper node3:2181,node4:2181,node5:2181 --topic 20170419 --partitions 2 --replication-factor 2
3、 查看当前服务器中的所有topic
./bin/kafka-topics.sh --list --zookeeper node3:2181,node4:2181,node5:2181
4、查看某个Topic的详情
./bin/kafka-topics.sh --describe --zookeeper node3:2181,node4:2181,node5:2181 --topic 20170419
5、修改某个topic的配置
./bin/kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181 --alter --topic test --config max.message.bytes=52428800
6、通过shell消费消息
./bin/kafka-console-consumer.sh --zookeeper node3:2181,node4:2181,node5:2181 --topic 20170419
7、通过shell命令发送消息
./bin/kafka-console-producer.sh --topic 20170419 --broker-list node3:9092,node4:9092,node5:9092
8、发送指定的文本里的内容
./bin/kafka-console-producer.sh --broker-list node3:9092,node4:9092,node5:9092 --topic test < /usr/local/test.txt --producer.config /usr/local/kafka10/config/producer.properties
9、通过shell消费消息
./bin/kafka-console-consumer.sh --zookeeper node3:2181,node4:2181,node5:2181 --topic car_events
10、删除topic
bin/kafka-topics.sh --delete --zookeeper node3:2181,node4:2181,node5:2181 --topic 20170419
需要server.properties中设置delete.topic.enable=true否则只是标记删除，改完配置之后要重启kafka才能生效。
