二、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才能生效。