学习 Apache Kafka(二):Kafka 1.0 单机环境搭建

👇以 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  

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