一、下载kafka
二、解压启动
tar -zxvf kafka_2.11-2.1.1.tgz -C 解压目录
三、
kafka依赖于zookeeper，现在的高版本自带zookeeper
启动zookeeper：
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
启动kafka：
./bin/kafka-server-start.sh ./config/server.properties
四、简单使用
在安装目录下：
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看创建的topic：
bin/kafka-topics.sh --list --zookeeper localhost:2181
生产者产生消息
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
然后输入相关的消息：
接下来消费者消费信息：
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
然后可以看到消费到刚才输入的消息
然后再输一些：
可以看到消费者这边已经自动出来了
五、关闭
可以在安装目录的bin目录下面查找以.sh结尾的文件。