kafka命令行操作
1、主题(Topic)命令行的操作
(1)查看topic的命令参数

bin/kafka-topics.sh 

(2)查看当前服务器中所有的topic

bin/kafka-topics.sh --bootstrap-server master:9092 --list 

(3)创建名为firstkafka的topic

bin/kafka-topics.sh --bootstrap-server master:9092 --create --partitions 1 --replication-factor 3 --topic firstkafka 

(4)查看firstkafka主题的详情

bin/kafka-topics.sh --bootstrap-server master:9092 --describe --topic firstkafka 

(5)修改分区数（注意：分区数只能增加，不能减少）

bin/kafka-topics.sh --bootstrap-server master:9092 --alter --topic firstkafka --partitions 3 

(6)再次查看firstkafka主题的详情

bin/kafka-topics.sh --bootstrap-server master:9092 --describe --topic firstkafka 

(7)删除topic

bin/kafka-topics.sh --bootstrap-server master:9092 --delete --topic firstkafka 

先开消费者，再开生产者。

2.生产者命令行操作

(1)查看操作生产者的命令参数

bin/kafka-console-producer.sh 

(2)发送消息

bin/kafka-console-producer.sh --broker-list master:9092 --topic firstkafka >hello world >bigdata 

3.消费者命令行操作

(1)查看操作消费者的命令参数

bin/kafka-console-consumer.sh 

(2)消费消息

消费firstkafka主题中的数据

bin/kafka-console-consumer.sh --bootstrap-server master:9092 --topic firstkafka 

把主题中所有的数据都读出来（包括历史数据）

bin/kafka-console-consumer.sh --bootstrap-server master:9092 --from-beginning --topic firstkafka