关于Kafka在本地进行部署の详细说明 ⑅︎◡̈︎*

——> 全文约 550 字 <——

Kafka的单机部署分为以下三步：

• 下载&安装
• 启动
• Topic 监听

下载&安装

目前 Kafka 已经更新到3.0.0，该版本是当前最稳定的版本，请点击此处 下载，当然你也可以在 Kafka官网 中下载指定的旧版本，比如我就是下载的2.4.1版本。

下载完后对压缩包进行解压，并将整个文件夹移动到你想要的位置，比如我的存放位置是：

/Users/Kay/Work/Tools/kafka/kafka_2.11-2.4.1

启动

启动顺序是：先启动 Zookeeper，再启动 Kafka，顺序不可以调换。

（同理关闭顺序是先关闭 Kafka 再关闭 Zookeeper）

• 启动 Zookeeper

  cd /Users/Kay/Work/Tools/kafka/kafka_2.11-2.4.1
  bin/zookeeper-server-start.sh config/zookeeper.properties
  

• 启动 Kafka（另起一个终端窗口）

  cd /Users/Kay/Work/Tools/kafka/kafka_2.11-2.4.1
  bin/kafka-server-start.sh config/server.properties
  

为了方便，我通常将上述命令写在脚本中，点击直接启动。

Topic监听

现在我已经启动了Kafka并往一个名为 kafka_topic_example 的 topic 中生产了一些数据，我要查看当前所有的 topics，我可以通过如下方式（ps. 我运行该命令无法查看我创建的 topic，暂时不知道为什么）：

cd /Users/Kay/Work/Tools/kafka/kafka_2.11-2.4.1
bin/kafka-topics.sh --list --zookeeper localhost:2181

我要查看当前 topic 的数据内容，可以通过如下方式：

cd /Users/Kay/Work/Tools/kafka/kafka_2.11-2.4.1
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic kafka_topic_example --from-beginning

如图所示，我现在能看到指定 topic 中的数据：

清空缓存

有时候会遇到直接关闭 Kafka 和 Zookeeper 的情况，这时候 Kafka 的缓存并不会被清空，由此可能会影响后续的使用，因此可以使用如下方式手动清空缓存：

rm -rf /tmp/kafka-logs/* # Kafka的缓存储存在该目录下

本文结束。