一、kafka安装

（1）解压

（2）修改名字为kafka212

（3）进入/opt/soft/kafka212/config目录，配置文件server.properties

21 broker.id=0
36 advertised.listeners=PLAINTEXT://192.168.91.11:9092
60 log.dirs=/opt/soft/kafka212/kfkdata
123 zookeeper.connect=192.168.91.11:2181
137 delete.topic.enable=true

（4）启动kafka前先启动zookeeper

#启动zookeeper
zkServer.sh start#启动kafka
nohup kafka-server-start.sh /opt/soft/kafka212/config/server.properties &

二、kafka常用命令

1、创建主题/创建表【create】

kafka-topics.sh --create --zookeeper 192.168.91.11:2181 --topic bigdate --partitions 3 --replication-factor 1

2、查看主题内容【list】

kafka-topics.sh --zookeeper 192.168.91.11:2181 --list

3、生产者，生产消息【producer】

kafka-console-producer.sh --topic a3 --broker-list 192.168.91.11:9092

4、消费者【consumer】

kafka-console-consumer.sh --bootstrap-server 192.168.91.11:9092 --topic a3 --from-beginning

5、查看队列详情【describe】

kafka-topics.sh --zookeeper 192.168.91.11:2181 --describe --topic kb23

6、查看队列消息数量/查看总的数据【GetOffsetShell】

kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.91.11:9092 --topic bigdata

7、删除topic/删除表【delete】

kafka-topics.sh --zookeeper 192.168.91.11:2181 --delete --topic kb23

8、其他
（1）退出安全模式

hdfs dfsadmin -safemode leave

（2）查看磁盘空间

df -h