文档章节

windows下安装kafka、zookeeper

求是科技
 求是科技
发布于 01/17 11:02
字数 695
阅读 337
收藏 2

前言

安装kafka之前必须安装jdk与zookeeper。
我安装的是jdk8,安装步骤这里省略。

1.安装zookeeper

1.到这个地址下载稳定版本的zookeeper版本,http://mirrors.shu.edu.cn/apache/zookeeper/ 。我下载的是当前最稳定的版本3.4.12。

2.解压到当前目录文件,到config目录下面,找到zoo_sample.cfg文件,将其名字修改成zoo.cfg。
3.编辑zoo.cfg文件,修改dataDir=D:/softCommon/zookeeper/zookeeper-3.4.12/data。将dataDir的目录设置成如上位置。
4.进入到zookeeper的bin目录下启动zookeeper。我的目录是:
5.启动成功。

2.安装kafka

1.到这个地址下载kafka版本,http://kafka.apache.org/downloads.html, 我下载的是2.12-2.1.0版本。
2.进入kafka的安装目录,到config目录下,修改server.properties文件,主要修改如下两个地方
log.dirs=D:\softCommon\kafka\kafka_2.12-2.1.0\logs zookeeper.connect=localhost:2181
说明:log.dirs表示kafka输出日志位置;zookeeper.connect表示kafka连接哪个zookeeper服务器。
3.启动kafka
输入命令:D:\softCommon\kafka\kafka_2.12-2.1.0>.\bin\windows\kafka-server-start.bat .\config\server.properties
注意如上命令是在kafka的安装目录下D:\softCommon\kafka\kafka_2.12-2.1.0>

3.应用kafka

3.1 创建主题
进入kafka的安装目录,D:\softCommon\kafka\kafka_2.12-2.1.0\bin\windows>
kafka创建topic命令:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
--create 创建主题
--zookeeper 连接到哪个zookeeper服务器(支持多个)
--replication-factor 每个分区的副本数
--partitions 分区数
--topic 主题名称
如上命令的理解:创建一个主题命名test,test只有一个分区,每个分区只有一个副本数,该kafka连接的zookeeper服务器localhost:2181
3.2 创建producer
进入kafka的安装目录,D:\softCommon\kafka\kafka_2.12-2.1.0\bin\windows>
kafka创建producer命令:kafka-console-producer.bat --broker-list localhost:9092 --topic test
--broker-list kafka集群包含多个服务,其中每个服务称为broker
--topic 主题名称
如上命令的理解:创建生产者的服务只有一个,即本机的localhost:9092, 生产者向主题为test的topic发消息。
3.3 创建consumer
进入kafka的安装目录,D:\softCommon\kafka\kafka_2.12-2.1.0\bin\windows>
kafka创建consumer命令:>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
--bootstrap-server kafka消费服务器指定,这里指定本地kafka来消费
--topic 消费主题名称
--from-beginning 表示从topic中第一条消息开始消费
如上命令的理解:消费者从主题为test的topic中消费消息,从第一条开始消费。
3.4 列出所有topic
命令:kafka-topics.bat -list -zookeeper localhost:2181
3.5 删除topic
命令:kafka-topics.bat --delete --zookeeper localhost:2181 --topic test6
--delete 删除命令

© 著作权归作者所有

求是科技

求是科技

粉丝 100
博文 456
码字总数 239071
作品 0
成都
后端工程师
私信 提问
Apache Kafka学习(三)之Kafka常用命令

1、开启zookeeper(在安装目录下使用命令) Linux:bin/zkServer.sh start windows:binzkServer.cmd 2、启动kafka(安装目录下使用命令) Linux:bin/kafka-server-start.sh start config/se...

zqcju
07/05
106
0
Windows 安装运行 Apache Kafka 教程

下面是分步指南,教你如何在Windows OS上安装运行Apache Zookeeper和Apache Kafka。 简介 本文讲述了如何在Windows OS上配置并启动Apache Kafka,这篇指南将会指导你安装Java和Apache Zookee...

大数据之路
2012/08/26
717
0
Winows上简单配置使用kafka(.net使用)

一、kafka环境配置 1.jdk安装 安装文件:http://www.oracle.com/technetwork/java/javase/downloads/index.html 下载JDK 安装完成后需要添加以下的环境变量(右键点击“我的电脑” -> "高级系...

未名天
10/23
0
0
windows下搭建Kafka运行环境

windows下搭建Kafka运行环境 http://www.bieryun.com/ 一、安装JDK jdk的安装就不再强调了 二、安装Zookeeper 由于Kafka的运行依赖于Zookeeper,所以在运行Kafka之前需要安装并运行Zookeeper...

优惠券发放
2018/11/22
0
0
kafka在windows上的安装、运行

kafka在windows上的安装、运行 目录(?)[+] 1.简介 Kafka是一种高吞吐量的分布式发布订阅消息系统。详细介绍可查阅官网:kafka官网 2.环境搭建 2.1 安装JDK 下载地址:jre下载 有关jdk的安装不...

yucaifu1989
2018/04/21
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Shell学习记录(持续更新)

一、shell定时备份数据库任务通用脚本 目标:根据定时任务启动脚本,执行数据库备份任务,按照日期进行每日备份,如已经备份则脚本停止,备份任务完成后将结果发送邮件提醒 1.执行数据库备份...

网络小虾米
今天
3
0
PHP计算两个经纬度地点之间的距离

/** * 求两个已知经纬度之间的距离,单位为米 * * @param lng1 $ ,lng2 经度 * @param lat1 $ ,lat2 纬度 * @return float 距离,单位米 * @author www.Alixixi.com */function get...

子枫Eric
今天
14
0
Linux—day 4

ch2 需要掌握的命令 (1)cat -n 1.txt (2)more 1.txt (3)head -n 15 initial-setup-ks.cfg (4)tail -n 17 initial-setup-ks.cfg;tail -f initial-setup-ks.cfg (5)cat -n anaconda-ks.c......

呵呵暖茶
今天
31
0
【Kubernetes社区之路】我的PR被抢了

2019年11月的某天,我无意间发现一个PR作者在自己的PR中抱怨自己的PR没被合入,而另一个比自己提交晚且内容几乎一样的PR则被合入了。 字里行间透露些许伤感外加无奈,原文如下: 作为一名开源...

恋恋美食
今天
40
0
阻塞队列

对于许多线程问题, 可以通过使用一个或多个队列以优雅且安全的方式将其形式化。生产者线程向队列插人元素, 消费者线程则取出它们。 使用队列, 可以安全地从一个线程向另 一个线程传递数据...

ytuan996
今天
48
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部