1.安装kakfka
1.从官网下载Kafka安装包，解压安装，或直接使用命令下载。
wget https://archive.apache.org/dist/kafka/0.11.0.0/kafka_2.11-0.11.0.0.tgz
2.解压
tar -xzvf kafka_2.11-0.11.0.0.tgz
2.修改配置文件
vim config/server.properties
broker.id=1
delete.topic.enable=true
log.dirs=/usr/local/kafka/logs
listeners=PLAINTEXT://localhost:9092
修改zookeeper.properties
dataDir路径
修改zookeeper连接地址
3.启动并测试
1.一定要先启动zookeeper服务
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
-daemon 是阻塞进程
2.启动单机kafka服务
bin/kafka-server-start.sh config/server.properties
3.创建topic进行测试
bin/kafka-topic.sh --create --zookeeper localhost:2128 --replication–factor 1 --partitions 1 --topic test
4.查看topic列表
bin/kafka-topic.sh --list --zookeeper localhost:9092 --topic test
输出test
5.生产者消息测试
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
6.消费者消息测试
bin/kafka-console-consumer.sh --zookeeper localhost:2128 --toptic test --from-beginning