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