正文

在windows环境中安装并使用kafka(代码片段)

lenmom  lenmom  2023-02-27  383

关键词：

1. 安装部署Java

下载需要安装的软件，下载地址：http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html
双节安装，并配置环境变量
使用下面的命令验证Java是否安装成功

java -version

至于怎么windows怎么安装java，此处不再赘述

2. 安装zookeeper

下载zookeeper并解压，下载地址：http://zookeeper.apache.org/releases.html，
选择自己需要的版本
进入zookeeper设置目录，将zoo_sample.cfg重命名为：zoo.cfg
在编辑器中打开zoo.cfg，将dataDir的值改成自己的data目录(需要新建)
新建zookeeper系统变量ZOOKEEPER_HOME=zookeeper根目录路径，并把bin目录添加到系统的path变量中

打开新的cmd，输入zkserver，运行Zookeeper服务器，如果安装成功，启动的界面如下：

ZooKeeper JMX enabled by default
Using config: d:workspacesoftware/zookeeper-3.4.12in..confzoo.cfg
Starting zookeeper ... STARTED

说明zookeeper已经安装成功并运行在2181端口。

具体请参见本人另外的博文《Windows安装和使用zookeeper》

3.安装kafka
下载需要的软件并解压，下载地址：
http://kafka.apache.org/downloads.html
进入kafka安装目录的config目录，修改server.properties文件，如修改的地方如下：
把log.dirs改成自己的目录，一般在kafka安装目录下新建文件夹来存放日志文件
Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181

4.运行kafka服务器
进入kafka安装目录，按下shift +右键，选择 "在此处打开命令窗口"，输入如下命令并按回车

.inwindowskafka-server-start.bat    .configserver.properties

注意：kafka依赖zookeeper,需要事先启动zookeeper.

5. 使用kafka

5.1 创建主题
进入kafka安装目录的inwindows下按shift +右键，选择“在此处打开命令窗口”，输入如下命令并回车：

kafak-topics.bat  --create --zookeeper localhost:2181 --replication-factor 1 --partition 1 --topic test

5.2 创建producer 及consumer来测试服务器
在kafka安装目录的inwindows启动新的命令窗口，producer和consumer需要分别启动命令窗口。
启动producter，启动命令如下：

kafka-console-producer.bat  --broker-list localhost:9092  --topic test

启动consumer，启动命令如下：

kafka-console-consumer.bat  --zookeeper localhost:2181  --topic test

在producter窗口输入内容，如果在consumer窗口能看到内容，则说明kafka安装成功

6. kafka常用命令

#列出主题
kafka-topic.bat -list -zookeeper localhost:2181  
#描述主题  
kafka-topics.bat -describe -zookeeper localhost:2181 -topic [topic name]   
#从头读取消息
kafka-console-consumer.bat -zookeeper localhost:2181 -topic [topic name] -from-beginning   
#删除主题
kafka-run-class.bat kafka.admin.TopicCommand -delete -topic [topic_to_delete] -zookeeper localhost:2181  
#查看topic的详细信息 
./kafka-topic.sh -zookeeper localhost:2181 -describe -topic  [topic name]    
#为topic增加副本
./kafka-reassign-partitions.sh -zookeeper localhost:2181 -reassignment-json-file json/partitions-to-move.json -execute  
#为topic增加partition
./bin/kafka-topics.sh -zookeeper localhost:2181 -alter -partitions 20 -topic [topic name]    
#下线broker
./kafka-run-class.sh kafka.admin.ShutdownBroker --zookeeper localhost:2181 broker [brokerId] --num.retries 3 --retry.interval.ms 60  shutdown broker

如何在cygwin中安装并配置ssh

...方法。还有苹果系统是支持FAT32这个分区格式的，可以在WINDOWS下将移动硬盘格式化成这种格式，就可以在苹果电脑下直接使用了。查看详情

java示例代码_在apache karaf中安装并运行osgi捆绑包

java示例代码_在apache karaf中安装并运行osgi捆绑包查看详情

在 AWS 启动配置中安装并启动 httpd

...】：2019-04-2605:51:28【问题描述】：我正在尝试为我的AWS云环境进行启动配置。当自动缩放组启动新的EC2实例时，我不想安装httpd并即时启动它。我可以手动通过SSH连接到实例并安装httpd：须藤百胜更新-y须藤百胜安装httpd-ysudo服务h... 查看详情

mingw和msys区别和关系以及mingw&msys在win7中安装并编译x264

1简介 MinGW，是MinimalistGNUforWindows的缩写。它是一个可自由使用和自由发布的Windows特定头文件和使用GNU工具集导入库的集合，允许你在GNU/Linux和Windows平台生成本地的Windows程序而不需要第三方C运行时（CRuntime）库。MinGW是... 查看详情

在 ubuntu 16.04 中安装并运行 kubeadm

】在ubuntu16.04中安装并运行kubeadm【英文标题】：installandrunkubeadminubuntu16.04【发布时间】：2018-08-2715:25:52【问题描述】：我使用的是ubuntu16.04，我是新手k8s。我正在关注这个官方文档。https://kubernetes.io/docs/setup/independent/install-kubeadm/... 查看详情

如何在cygwin中安装并配置ssh

...上OpenSSH和OpenSSL两项4.等待下载并完成安装，之后，设置环境变量，把C:/cygwin/bin;C:/cygwin/u.参考技术A1.下载Cygwin安装文件2.运行安装文件，选择一个下载站点，继续3.选择要安装的程序，默认是不安装OpenSSH的，需要手动选择，在Net... 查看详情

在 laravel 6 版本中安装并启用 PHP Redis 扩展

】在laravel6版本中安装并启用PHPRedis扩展【英文标题】：PHPRedisextensionisinstalledandenabledinlaravel6version【发布时间】：2020-04-0107:32:51【问题描述】：当我尝试在larvel6版本中安装redis时，我无法安装redis，它的扩展显示错误。【问题讨... 查看详情

在docker中安装并修改mysql中的my.cnf配置文件(代码片段)

前言前期经过MySQL主从复制之后，发现数据库的读写非常慢，而且经常发生MySQL连接数过小，导致整个数据库崩溃的情况。通过修改MySQL中的my.cnf配置文件参数，以达到MySQL关系型数据库最大性能的合理利用。本文... 查看详情

0030-如何在cdh中安装kudu&spark2&kafka(代码片段)

...特定的Parcel包才能安装相应服务。本文档主要描述在离线环境下，在CentOS6.5操作系统上基于CDH5.12.1集群，使用ClouderaManager通过Parcel包方式安装Kudu、Spark2和Kafka的过程。内容概括Kudu安装S 查看详情

在 javascript/Angular JS 中安装并打开 Android /ios 原生应用程序

】在javascript/AngularJS中安装并打开Android/ios原生应用程序【英文标题】：InstallandopenAndroid/iosnativeapplicationinjavascript/AngularJS【发布时间】：2013-08-1012:22:23【问题描述】：我们的移动Web应用程序中有“扫描”按钮。移动Web应用程序完... 查看详情

kali中安装并使用dsniff中的arpspoof和urlsnarf

简介dsniff是一款很好用的嗅探工具,里面有arpspoof和urlsnarf这两个工具安装apt-getinstalldsniff使用介绍注意:如果没有arpspoof或者说没有dsniff的话,kali会自动提示安装的,如果是新安装的kali,可能会装不上,因为kali的源默认是国外的,所以需... 查看详情

在windows环境中安装neo4j(代码片段)

文章目录项目演示:[Neo4j第一篇：在Windows环境中安装Neo4j](https://www.cnblogs.com/ljhdo/p/5521577.html)**一，安装Neo4j****二，Neo4j的配置****三，网络连接配置****四**，**启动Neo4j程序****五，Neo4j集成的浏览器* 查看详情

vue-cli中安装并使用less

首先安装vue-cli，网站教程多多，在这不多说。接下来在vue项目目录下，运行其他扩展使用方法我放个官网链接，大家可以点击查看npminstalllessless-loader--save-dev等待安装成功即可，接下里我们可以在vue项目中的package.json中看到less... 查看详情

当我在项目应用程序中安装并链接 react-native-admob 在加载时崩溃

】当我在项目应用程序中安装并链接react-native-admob在加载时崩溃【英文标题】：Wheniinstalledandlinkreact-native-admobinprojectapplicationgotcrashonloadtime【发布时间】：2019-01-2314:06:14【问题描述】：在安装react-native-admob之前，我在react-native中... 查看详情

windows环境使用kafka

...sp;http://kafka.apache.org/quickstart官网上是linux环境，我用的是windows环境。已经安装过jdk1下载kafka,地址 http://kafka.apache.org/downloads 2解压，我把它解压到 D 查看详情

window环境搭建zookeeper,kafka集群(代码片段)

为了演示集群的效果，这里准备一台虚拟机(window7)，在虚拟机中搭建了单IP多节点的zookeeper集群（多IP节点的也是同理的），并且在本机（win7）和虚拟机中都安装了kafka。前期准备说明：1.三台zookeeper服务器，本机安装一个作为ser... 查看详情

kafka基于windows的kafka有关环境搭建以及使用.net环境开发的案例代码与演示...

前言：基于Windows系统下的Kafka环境搭建；以及使用.NET 6环境进行开发简单的生产者与消费者的演示。一、环境部署Kafka是使用Java语言和Scala语言开发的，所以需要有对应的Java环境，以及Scala语言环境。Java环境配置... 查看详情

windows下安装并使用kafka(代码片段)

安装部署安装Java环境下载需要安装的软件，下载地址：http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html双节安装，并配置环境变量使用下面的命令验证Java是否安装成功安装ZooKeeper下载zookeeper并解压，下载地址：ht... 查看详情