安装
安装 Kafka 需要 Java 环境和 Zookeeper 环境（新版不需要 Zookeeper 环境，因为已经内置类Zookeeper 环境）
Windows 和 Linux 安装都是一样的，从 官网 下载 Kafka 最新版本，下载后不需要安装，解压即可使用。
选择版本.png
下载.png
这里主要说一下 Linux 下的下载与解压
切换到 /usr/local/ 目录
cd /usr/local/
复制下载链接，使用 wget 命令下载
sudo wget http://archive.apache.org/dist/kafka/1.0.0/kafka_2.11-1.0.0.tgz
解压
sudo tar -zxvf kafka_2.11-1.0.0.tgz
重命名
sudo mv kafka_2.11-1.0.0/ kafka
使用
前面是 windows 命令，后面是 Linux 命令，根据安装环境使用不同命令。使用命令需要切换到 Kafka 的安装目录
1. 启动 Zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
bin/zookeeper-server-start.sh config/zookeeper.properties
2. 启动 Kafka
bin\windows\kafka-server-start.bat config\server.properties
bin/kafka-server-start.sh config/server.properties
3. 创建主题
以下命令创建了一个名为“test”的topic，它有一个分区和一个副本。
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
可以是用 list 命令查看刚刚创建的 topic
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
bin/kafka-topics.sh --list --zookeeper localhost:2181
4. 生产者
启动一个 生产者 控制台，向 test 主题发送消息。
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
5.消费者
启动一个消费者，接收 test 主题的消息
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
zookeeper默认端口：2181， kafka 默认端口：9092
