Kafka是由Apache软件基金会开发的一个开源流处理平台，同时也是一个高吞吐量的分布式发布订阅消息系统。它由Scala和Java编写，具有多种特性和广泛的应用场景。
Kafka是一个分布式消息系统，它允许生产者（Producer）发布消息到指定的主题（Topic），消费者（Consumer）可以订阅这些主题并消费其中的消息。
Kafka具有高吞吐量、低延迟、可扩展性、持久性、可靠性等特性，非常适合处理大规模数据流和实时数据处理任务。
ZooKeeper是一个分布式的、开放源码的分布式应用程序协调服务，它为分布式应用提供一致性服务。
1、安装Zookeeper
下载地址：Apache Download Mirrors
下载pache-zookeeper-3.9.2-bin.tar.gz
解压：tar -zxvf apache-zookeeper-3.9.2-bin.tar.gz -C ~/training/
2、配置Zookeeper环境变量：
> vi ~/bashrc, 在最下面添加：
ZOOKEEPER_HOME=/home/worker/training/apache-zookeeper-3.9.2-bin
export ZOOKEEPER_HOME
PATH=$ZOOKEEPER_HOME/bin:$PATH
export PATH
3、配置conf/zoo.cfg:
dataDir=/home/worker/training/apache-zookeeper-3.9.2-bin/tmp/zookeeper
server.1=demo1:2888:3888 //demo1是主机名
在/home/worker/training/apache-zookeeper-3.9.2-bin/tmp目录下创建文本文件myid，写入1。
4、启动zookeeper
./bin/zkServer.sh start
5、下载Kafka
下载地址：Apache Kafka
下载 kafka_2.13-3.8.0.tgz
tar -zxvf kafka_2.13-3.8.0.tgz -C ~/training/
6、配置kafka
vi ~/training/kafka_2.13-3.8.0/config/server.properties
log.dirs=/home/worker/training/kafka_2.13-3.8.0/tmp/kafka-logs
vi ~/training/kafka_2.13-3.8.0/config/zookeeper.properties
dataDir=/home/worker/training/apache-zookeeper-3.9.2-bin
7、测试Kafka收发消息
启动kafka：
bin/kafka-server-start.sh config/server.properties&
创建主题：
./bin/kafka-topics.sh --create --bootstrap-server demo1:9092 --replication-factor 1 --partitions 1 --topic mydemo1
启动生产者：
bin/kafka-console-producer.sh --broker-list demo1:9092 --topic mydemo1
启动消费者：
bin/kafka-console-consumer.sh --bootstrap-server demo1:9092 --topic mydemo1
测试方法：在生产者终端输入信息，在消费者终端即可同步显示，如下图所示：
