0.引言
kafka是一个高性能分布式的MQ，今天我们就来玩玩
1.安装
wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz
这是下载完的样子：
tar -zxvf kafka_2.11-2.3.0.tgzcd kafka_2.11-2.3.0/
修改 kafka-server 的配置文件
cd configvi server.properties
打开后如下所示
将这俩位置改一下
到此安装结束 *** 2.启动
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties #启动zookeeperbin/kafka-server-start.sh config/server.properties #启动kafka
成功启动
使用 kafka-topics.sh 创建单分区单副本的 topic test：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testbin/kafka-topics.sh --list --zookeeper localhost:2181 #查看列表
3.产生消息
使用kafka-console-producer.sh 发送消息
使用kafka-console-consumer.sh 接收消息 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
至此完成Kafka单机配置