Kafka的保姆级简易安装启动、关闭注意事项、简单使用

一.安装:

1.1Windows本机tar包安装

1.下载tar包

地址:Apache Download Mirrors,点击下面的连接先将tar包下载下来

 2.解压到任意地址但自己要记得位置

 3.进入到config文件找到server.properties更改信息

搜索,然后找到下面的地方将下面代码复制进去。server.properties文件可以用于配置监听的host、port、broker等

注意:这个zookeeper.connect=localhost:2181和log.dirs=./logs是原先就有的,找到修改即可。默认的ZooKeeper连接服务为localhost:2181

#存储到日志文件夹中
log.dirs=./logs#本地的zookeeper
zookeeper.connect=localhost:2181

然后把这份文件复制一份到Windows下 

 4.启动Kafka

如果没有本机原先没有的可以进入到bin目录用自带的zookeeper。

进入D:\Kafka\kafka_2.12-2.4.0目录下打开两个cmd窗口,一个启动zookeeper一个启动kafka,使用命令(先启动zookeeper再启动)。

.\bin\windows\zookeeper-server-start.bat config\zookeeper.properties.\bin\windows\kafka-server-start.bat .\config\server.properties

 上面的要根据实际情况来更换,有些可能是sh的而不是bat

 当出现下面的信息即启动成功

如果出现以下情况,则需要到环境变量配置一下

进入到C:\Windows\System32\wbem,查看是否有WMIC.exe

然后再Path下添加C:\Windows\System32\wbem即可

1.2Docker安装

# docker直接拉取kafka和zookeeper的镜像
docker pull wurstmeister/kafka
docker pull wurstmeister/zookeeper 
# 首先需要启动zookeeper,如果不先启动,启动kafka没有地方注册消息
docker run -it --name zookeeper -p 12181:2181 -d wurstmeister/zookeeper:latest
# 启动kafka容器,注意需要启动三台,注意端口的映射,都是映射到9092
# 第一台
docker run -it --name kafka01 -p 19092:9092 -d -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.233.129:12181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.233.129:19092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:latest
# 第二台
docker run -it --name kafka02 -p 19093:9092 -d -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.233.129:12181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.233.129:19093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:latest
# 第三台
docker run -it --name kafka03 -p 19094:9092 -d -e KAFKA_BROKER_ID=2 -e KAFKA_ZOOKEEPER_CONNECT=192.168.233.129:12181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.233.129:19094 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:latest

二.kafka关闭

kafka关闭是切记尽量!!!!不要直接关闭命令行窗口,此为暴力关闭,可能会导致kafka无法对日志文件的解锁,再启动的时候无法启动成功。且就算关闭也要按照先关闭kafka再关闭zookeeper的顺序。

建议:通过在命令行执行kafka-server-stop命令来关闭它。

三.简单使用:

1.新建topic

进入到bin下的Windows新建一个cmd窗口,输入命令,创建了一个test的topic

kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test --partitions 1 -replication-factor 1

 

2.查看topic

kafka-topics.bat --list --bootstrap-server localhost:9092

 

参考文章:

看完这篇Kafka,你也许就会了Kafka_心的步伐的博客-CSDN博客

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/14571.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

uniapp打包app,对接华为厂商,实现unipush离线消息推送

今天终于可以抽出点时间,来记录一下这几天心塞的心情。上周公司派过来一个活,说是使用uniapp制作一个app,同时要实现在线消息推送和离线消息推送,啥话没说就揽了下来。不过说实在的,从来没有开发过app,好歹…

SpringMVC原理分析 | 数据处理:ModelAndView

💗wei_shuo的个人主页 💫wei_shuo的学习社区 🌐Hello World ! 重定向和转发 ModelAndView 设置ModelAndView对象,根据view的名称、视图解析器跳转到指定的页面 页面:{视图解析器前缀} viewName {视图解析器…

基于matlab对于未校准立体图像校正(附源码)

一、前言 此示例说明如何计算两个未校准图像的校正,其中相机内禀函数未知。 立体图像校正将图像投影到公共图像平面上,以使相应的点具有相同的行坐标。此过程对于立体视觉很有用,因为 2-D 立体对应问题被简化为 1-D 问题。例如,…

网络应用基础ENSP环境的安装(NETBASE第三课)

网络应用基础ENSP环境的安装(NETBASE第三课) eNSP(Enterprise Network Simulation Platform)是一款由华为提供的、可扩展的、图形化操作的网络仿真工具平台,主要对企业网络路由器、交换机进行软件仿真,完美呈现真实设备实景,支持大型网络模拟…

vue3+pinia用户信息持久缓存(token)的问题

vue3pinia用户信息持久缓存(token)的问题 对博主来说,这是个相当复杂的问题。 当初在使用vue2vuex进行用户信息持久登录时,写了不下3篇博客,确实是解决了问题,博客链接如下 vue存储和使用后端传递过来的tokenvue中对…

抖音短视频矩阵管理系统源码开发部署(开源定制)

一、什么是短视频矩阵管理系统? 短视频矩阵管理系统是专门为企业号商家、普通号商家提供帐号运营从流量 到转化成交的一站式服务方案,具体包含:点赞关注评论主动私信 ,评论区回复,自动潜客户挖掘,矩阵号营销…

Maven高级(四)--私服

一.作用 我们所拆分的模块是可以在同一个公司各个项目组之间的项目组之间进行资源共享的,这就需要Maven的私服来实现。 二.场景 两个项目组之间如何基于私服进行资源的共享的呢? 例如A开发了一个模块tlias-utils,B团队进行项目开发,要想使用…

身高排队,不是你想的那么简单——力扣“按身高排序”题解分析

本篇博客会讲解力扣“2418. 按身高排序”的解题思路,这是题目链接。 想要排序身高数组是非常简单的。我们在对身高数组进行排序时,会进行一些操作,比如交换2个元素等等。本题中,相当于我们要“记住”排序身高数组中进行了哪些操作…

2023校招,2024校招,社招Shein,大量HC,使用内推码直达,流程快速

广州,深圳,南京,大量开发岗位,包含Java开发岗,前端开发岗大数据开发岗位,产品岗位,测试岗位等等,大量hc,欢迎大家投递Shein,打造全球化的快时尚跨境电商品牌

【计算机视觉 | 图像分割】arxiv 计算机视觉关于图像分割的学术速递(7 月 4 日论文合集)

文章目录 一、分割|语义相关(18篇)1.1 TomatoDIFF: On-plant Tomato Segmentation with Denoising Diffusion Models1.2 CGAM: Click-Guided Attention Module for Interactive Pathology Image Segmentation via Backpropagating Refinement1.3 RefSAM: Efficiently Adapting …

Pico版节奏光剑简单制作

视频教程参考:Pico VR Neo3开发实战教程(1)——节奏光剑,舞台灯效_哔哩哔哩_bilibili 1、新建项目和pico配置 插件导入 找到下载的pico SDK 选择json文件,点击即可导入 启用插件 在 Project Settings 窗口中&#xf…

Spring AOP讲解及实例

Aop面向切面编程 文章目录 Aop面向切面编程什么是AOPAOP术语Spring AOP 的使用导入依赖编写切面类切面定义语法小细节输出日志成功 什么是AOP AOP:(Aspect Oriented Programming)面向切面编程,和OOP(Object Oriented …