中间件:Win10安装运行Kafka
创始人
2024-05-05 13:04:23
0

一、JDK环境安装配置

可参考:百度安全验证

二、Zookeeper安装配置

 1、下载  : Index of /dist/zookeeper/zookeeper-3.4.9

 

 2、解压到本地,目录不要带中文符号,保证纯英文

 3、zoo.cfg修改

 4、cmd运行,使用命令zkServer 

三、Kafka安装

1、下载:Apache Kafka

2、配置文件 kafka_2.12-0.11.0.0\config  server.properties

默认在9092端口上运行,并连接zookeeper的默认端口:2181

可修改  zookeeper.connect=localhost:2181

3、启动kafka

指定配置文件CMD启动:   .\bin\windows\kafka-server-start.bat .\config\server.properties

四、测试

1、创建主题

 .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test_demo

2、查看主题

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

3、创建生产者,消费者,使用主题 test_demo,生产者推送消息,消费者订阅成功

 生产者:  .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test_demo

消费者:.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 -topic test_demo --from-beginning

 

 

相关内容

热门资讯

监控摄像头接入GB28181平... 流程简介将监控摄像头的视频在网站和APP中直播,要解决的几个问题是:1&...
Windows10添加群晖磁盘... 在使用群晖NAS时,我们需要通过本地映射的方式把NAS映射成本地的一块磁盘使用。 通过...
protocol buffer... 目录 目录 什么是protocol buffer 1.protobuf 1.1安装  1.2使用...
在Word、WPS中插入AxM... 引言 我最近需要写一些文章,在排版时发现AxMath插入的公式竟然会导致行间距异常&#...
Fluent中创建监测点 1 概述某些仿真问题,需要创建监测点,用于获取空间定点的数据࿰...
educoder数据结构与算法...                                                   ...
MySQL下载和安装(Wind... 前言:刚换了一台电脑,里面所有东西都需要重新配置,习惯了所...
MFC文件操作  MFC提供了一个文件操作的基类CFile,这个类提供了一个没有缓存的二进制格式的磁盘...
有效的括号 一、题目 给定一个只包括 '(',')','{','}'...
【Ctfer训练计划】——(三... 作者名:Demo不是emo  主页面链接:主页传送门 创作初心ÿ...