windows安装及简单使用kfaka(单机)

1.下载
管网下载链接，进入后页面如下：

kfaka官网.png

点击红框中的链接即可下载，此版本为当前最新版本。

下载完成后，先添加一个logs文件夹，后面会用到，目录如下：

kfaka目录.png

2.使用

• 修改配置文件
  进入config文件夹，打开server.properties文件，修改log.dirs为F://kfaka//kafka_2.12-2.3.0//logs

• 启动kfaka

前提条件：需要先启动zookeeper，可参考这篇文章windows 安装启动 zookeeper（单机）
注意：启动zookeeper前确保它的data和logs文件夹没有文件和文件夹，不然后面会出问题

启动kfaka命令：
在命令行靠窗口（切换路径到F:\zookeeper\apache-zookeeper-3.5.5-bin,即kfaka根路径）输入
.\bin\windows\kafka-server-start.bat .\config\server.properties,服务器启动完成。

• 创建topic
  另开命令行窗口，在命令行靠窗口（切换路径到F:\zookeeper\apache-zookeeper-3.5.5-bin,即kfaka根路径）输入
  kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

• 创建生产者
  另开命令行窗口，在命令行靠窗口（切换路径到F:\zookeeper\apache-zookeeper-3.5.5-bin,即kfaka根路径）输入
  kafka-console-producer.bat --broker-list localhost:9092 --topic test，页面如下：
  producctor.png

• 创建消费者
  另开命令行窗口，在命令行靠窗口（切换路径到F:\zookeeper\apache-zookeeper-3.5.5-bin,即kfaka根路径）输入
  kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test，页面如下：
  custormer.png

-测试
以上步骤完成后，可以在生产者的命令行窗口输入信息，输入完成后，消费者命令窗口会收到信息,上面的两张图的“kk”就是一个例子

• 可能会遇到的bug
  Exception causing close of session 0x0: null

出现这个问题就是因为在启动zookeeper之前，zookeeper的data和logs文件夹已经有了脏数据，需要先删掉，再启动，然后依次启动kfaka各组件。