1. 安装zookeeper
下载地址:http://mirrors.hust.edu.cn/apache/zookeeper/
在根目录新建data文件
修改conf\zoo_sample.cfg 文件名改成 zoo.cfg
修改dataDir的值路径,将dataDir=/tmp/zookeeper改成dataDir=“本地data文件路径”
在bin目录下启动cmd,输入zkServer.cmd启动服务
** 启动后窗口不要关闭

2. 安装kafka
下载地址:http://kafka.apache.org/downloads.html
根目录config文件夹下的server.properties文件,用记事本打开,将log.dirs的值改成log.dirs=E:\kafka_2.12-0.10.2.0\logs
启动kafka服务
进入kafka解压文件根目录,执行命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
** 启动后窗口不要关闭
创建Topic
进入bin\windows目录下启动cmd,执行命令
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
** 启动后窗口不要关闭
windows上kafka安装、启动
创建生产者Producer
进入bin\windows启动cmd,执行命令
kafka-console-producer.bat --broker-list localhost:9092 --topic test
windows上kafka安装、启动
创建消费者consumer
进入bin\windows启动cmd,执行命令
.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
windows上kafka安装、启动
这样就可以了,在生产者窗口输入消息,就可以直接在消费者窗口看到了

相关文章:

  • 2021-05-31
  • 2022-01-22
  • 2021-11-10
  • 2021-12-19
  • 2021-09-04
  • 2021-07-03
  • 2021-04-25
  • 2021-06-17
猜你喜欢
  • 2021-10-22
  • 2021-08-03
  • 2021-05-21
  • 2022-12-23
  • 2021-12-02
  • 2021-08-17
  • 2022-12-23
相关资源
相似解决方案