Kafka 安装与使用

安装

安装 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