[聚合文章] 学习 Apache Kafka（二）：Kafka 1.0 单机环境搭建

:point_down:以 Ubuntu 16.04 为例，搭建单机 Kafka 1.0 环境，单机环境只适合开发使用

安装 Java 8

安装 Java 8：

sudo add-apt-repository ppa:webupd8team/java  
sudo apt-get update  
sudo apt-get install oracle-java8-installer

验证安装：

java -version

安装并配置 ZooKeeper

访问 ZooKeeper 官网 ，下载 zookeeper-3.4.11.tar.gz 并解压缩：

tar -zxf zookeeper-3.4.11.tar.gz

修改 conf/zoo.cfg 文件：

tickTime=2000  
dataDir=/var/lib/zookeeper  
clientPort=2181

创建数据文件目录：

mkdir -p /var/lib/zookeeper

启动 ZooKeeper 服务：

bin/zkServer.sh start

安装并配置 Kafka Broker

访问 Kafka 官网 ，下载 kafka_2.11-1.0.0.tgz 并解压缩：

tar -zxf kafka_2.11-1.0.0.tgz

创建日志目录：

mkdir /tmp/kafka-logs

启动 Kafka 服务：

bin/kafka-server-start.sh -daemon config/server.properties

验证

创建一个测试 topic，副本数为 1 分区数为 1：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

topic 创建成功之后，可以向 topic 发布消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

输入几行消息，按 control + D 退出

从 topic 订阅消息：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

如果配置没有问题，就会在终端打印出刚刚输入的几行消息