本文主要记录在win10环境搭建kafka+zookeeper

一、安装jdk1.8

二、安装zookeeper

下载安装包:http://zookeeper.apache.org/releases.html#download

进入文件目录:C:\apache-zookeeper-3.5.8-bin\apache-zookeeper-3.5.8-bin\conf,将“zoo_sample.cfg”重命名为“zoo.cfg”

找到并编辑dataDir=C:\\apache-zookeeper-3.5.8-bin\\apache-zookeeper-3.5.8-bin\\temp(注意使用双斜线)

与Java中的做法类似,我们在系统环境变量中添加:
  a. 在系统变量中添加ZOOKEEPER_HOME = C:\apache-zookeeper-3.5.8-bin\apache-zookeeper-3.5.8-bin
  b. 编辑path系统变量,添加为路径%ZOOKEEPER_HOME%\bin;

在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)

打开新的cmd,输入zkServer,运行Zookeeper。(注意需要占用8080端口)

 命令行保持运行:说明本地Zookeeper启动成功

三、安装kafka

下载http://kafka.apache.org/downloads.html。注意要下载二进制版本的

进入conf文件编辑文件“server.properties”

修改日志目录

找到并编辑zookeeper.connect=localhost:2181

Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。

启动kafa:在命令行中输入   .\bin\windows\kafka-server-start.bat .\config\server.properties  ,命令行需要在安装kafa的目录(如C:\kafka_2.12-2.6.0\kafka_2.12-2.6.0)。

四、使用kafka

命令行需要在安装kafa的目录(如C:\kafka_2.12-2.6.0\kafka_2.12-2.6.0)

  1. 创建topic:.\bin\windows\kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic topic1

  2. 创建生产者:.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topic1

  3. 创建消费者:.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic1

  4. 在两个cmd窗口测试:

Kafka+zookeeper搭建过程

 

相关文章:

  • 2022-12-23
  • 2021-12-22
  • 2021-11-18
  • 2021-11-18
  • 2021-11-18
  • 2021-08-05
猜你喜欢
  • 2021-11-18
  • 2021-11-18
  • 2021-10-12
  • 2021-12-08
  • 2021-11-02
  • 2021-10-10
相关资源
相似解决方案