kafka的windows安装使用

kafka的windows安装使用 安装JDK，安装Zookeeper，安装Kafka，依次启动

zookeeper的作用

1. Broker和Topic注册：分布式部署，需要一个东西来管理，那个就是Zookeeper，broker节点的维护，topic话题的分区情况维护都是Zookeeper记录的。
2. 生产者和消费者的负载均衡：生产者需要将消息合理地发送到这些分布式的Broker上。
3. 记录消费者组和分区的关系
4. 记录话题分区上的消费进度
5. 消费者的注册

流程如下

1. 下载安装包 http://zookeeper.apache.org/releases.html#download （我安装了apache-zookeeper-3.5.9-bin，解压到D://developSoftware）
2. 将“config/zoo_sample.cfg”重命名为“zoo.cfg”
3. 打开zoo.cfgs更改dataDir
4. 添加系统变量，增加ZOOKEEPER_HOME对应你解压到的目录对应目录，然后编辑变量Path新增对应bin目录。
   

5. 安装jdk1.8 https://www.oracle.com/java/technologies/downloads/#java8，安装成功后配置变量

6. 配置好后直接使用cmd命令zkServer，zkServer是你配置环境变量时对应的bin目录里面的文件，出现此类提示表示开启Zookeeper成功，开启后不能删除窗口。
   
   

7. 安装kafka ，http://kafka.apache.org/downloads安装带有binary（二级制）文件

8. 解压后进入config目录找到文件server.properties并打开，设置

   • zookeeper.connect=localhost:2181（这个需要和zookeeper的/conf/zoo.cfg的clientPort=2181一致）
   • log.dirs=/tmp/kafka-logs（这个是记录你kafka分区的信息，可以改到你喜欢地址）

9. 开启kafka，进入kafka的目录cmd执行 .binwindowskafka-server-start.bat .configserver.properties，开启成功后会， log.dirs=/tmp/kafka-logs目录会出现这些文件，当你出现cluster.id不匹配，但第一次启动成功时，可能时是你关闭的时候没有好好的关闭程序导致的，你需要删除图片红框里的文件，在重新启动。