启动kafka集群以及关闭

kafka操作

第一个窗口

cd /root/software/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

在这里插入图片描述
在这里插入图片描述
最后这种就是成功了

Zookeeper 启动

  • Zookeeper 是 Kafka 集群的协调服务,启动 Kafka 之前必须确保 Zookeeper 正在运行。

第二个窗口:有时候一次没成功得是第二次第三次

cd /root/software/kafka
bin/kafka-server-start.sh config/server.properties

在这里插入图片描述
在这里插入图片描述

Kafka 服务器启动

  • 在启动 Kafka 服务器时,确保 Zookeeper 已经成功启动。
  • 如果 Kafka 服务器启动失败,查看日志文件以确定失败原因,可能是配置错误或端口冲突。

第三个窗口

cd /root/software/kafka
#创建一个主题topic,在这里我们可以进行别的操作
bin/kafka-topics.sh --create --topic _demo --bootstrap-server localhost:9092
#查看已经有的主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
#查看使用 --describe 参数来获取特定主题
bin/kafka-topics.sh --describe --topic demo1 --bootstrap-server localhost:9092

开始给话题发送命令

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic _demo
  • bin/kafka-console-producer.sh:这是启动 Kafka 生产者客户端的脚本文件。
  • --broker-list localhost:9092:指定 Kafka 集群的地址列表。在这里,它连接到运行在本地主机(localhost)的 Kafka 服务器,默认端口为 9092。
  • --topic _demo:指定目标 Kafka 主题,即你想要发送消息的主题。在这个例子中,主题名称为 _demo
    在这里插入图片描述

第四个窗口

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic _demo
  • bin/kafka-console-consumer.sh:这是启动 Kafka 消费者客户端的脚本文件。
  • --bootstrap-server localhost:9092:指定 Kafka 集群的地址。在这里,它连接到运行在本地主机(localhost)的 Kafka 服务器,默认端口为 9092。
  • --topic _demo:指定要消费消息的 Kafka 主题。在这个例子中,主题名称为 _demo

运行此命令后,控制台将开始显示从主题 _demo 接收到的消息。这是一种实时监控 Kafka 主题消息的便捷方式。

在这里插入图片描述

关闭 Kafka 集群的顺序相当重要,以确保所有组件都可以优雅地关闭,避免数据丢失或损坏。一般建议的关闭顺序是:

  1. 先关闭 Kafka 生产者和消费者客户端
    • 确保所有发送到 Kafka 的消息都已经被处理,并且没有新的消息被发送。
  2. 关闭 Kafka 服务器
    • 执行 Kafka 服务器的关闭脚本。这将确保 Kafka 服务器优雅地关闭,提交所有必要的数据到磁盘。
  3. 最后关闭 Zookeeper 服务器
    • 由于 Kafka 依赖于 Zookeeper 进行协调,因此 Zookeeper 应该在 Kafka 服务器完全关闭之后才关闭。
    • 关闭 Zookeeper 可以通过执行 Zookeeper 关闭脚本来实现。

按照这个顺序关闭 Kafka 集群可以最大程度地减少关闭过程中可能出现的问题,比如数据不一致或者服务无法正常回复。

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

谨慎Apache-Zookeeper-3.5.5以后在CentOS7.X安装的坑

目录 前言 一、现场还原 二、问题诊断 三、问题原因 总结 前言 最近由于项目需要,在服务器上需要搭建Hbase完全分布式集群环境。开发环境,采用的是最小节点的方式进行搭建(即3个节点的模式)。资源环境列表如下: 序号…

CentOS7搭建Kubernetes集群

环境准备:配置好静态IP地址的Centos7(2核、master内存3GB、slave内存2GB)。 搭建概述:先将一台虚拟机搭建为master、随后克隆出两台虚拟机作为从节点。 虚拟机主机名和IP地址: 主机名IP地址master192.168.138.110sl…

python类的多重继承继承和查找顺序

1 python类的多重继承继承和查找顺序 python中,类的多重继承允许子类继承多个基类,子类可以访问多个基类的属性和方法。 1.1 多重继承基础 用法 class MulClass(BaseC1,BaseC2,...BaseCn):pass描述 Mulclass:子类(或者称混合…

网络核心知识总结

计算机网络总结 基础 网络分层模型 OSI 七层模型是什么?每一层的作用是什么? OSI 体系结构是法律上的国家标准,从上往下讲分别是: 应用层 – 作用是 – 为计算机用户提供服务表示层 – 作用是 – 数据处理(编解码、加密解密、…

【数据结构】八大排序 (三)

目录 前言: 快速排序 快速排序非递归实现 快速排序特性总结 归并排序 归并排序的代码实现 归并排序的特性总结 计数排序 计数排序的代码实现 计数排序的特性总结 前言: 前文快速排序采用了递归实现,而递归会开辟函数栈帧&#xff0…

赴日开发做什么?日本签证很难拿?

日本的IT行业历史比较悠久,业务以上层前端业务为主,如设计和构建软件。日本IT公司组织庞大,行业内部有着严格的分工和部署,工作会被细分化。分配给个人的工作量不会太大,难度也不会很高。 在日本IT公司就业&#xff0…

【古月居《ros入门21讲》学习笔记】06_ROS常用命令行工具

目录 说明: 1. 回顾小海龟案例 终端1:启动ROS master 终端2:启动小海龟仿真器 终端3:启动海龟控制节点: 2. 系统计算图:rqt_graph 3. rosnode rosnode list:显示节点列表 rosnode info&…

LESS的叶绿素荧光模拟实现——任意波段荧光模拟

目录 前言一、任意波段荧光模拟的实现二、需要注意的输入参数 前言 此专栏默认您对LESS (LargE-Scale remote sensing data and image Simulation framework) 模型和叶绿素荧光(Sun-Induced chlorophyll Fluorescence, SIF)有一定的了解。当然,您也可以在这里下载中…

NCo3.1(08) - Nco3 服务器端编程

本篇博文不再重复ABAP调用外部服务器的基础,只介绍 NCo3 开发的过程和要点。需要了解相关知识点的小伙伴们自行参考: SAP接口编程 之JCo3.0系列(06) - Jco服务器端编程 PyRFC 服务器端编程要点 创建项目 新建一个 Console 项目,选择 .Net …

(亲测有效)解决windows11无法使用1500000波特率的问题

大家好!我是编码小哥,欢迎关注,持续分享更多实用的编程经验和开发技巧,共同进步。 1、问题描述 从图1可以看出串口是正常的,安装的驱动是CP210xVCPInstaller_x64.exe,但是从图2可以看出,串口拒…

C# WPF 基础教程——触发器、行为、形状、变换与透明、路径和几何图形

触发器 简单触发器 单条件触发器 多条件触发器 事件触发器 行为 形状 矩形和椭圆 Viewbox缩放控件,直线,折线,多边形 画刷 普通画刷 线性渐变画刷 环形渐变画刷 位图画刷 虚拟画刷(复制元素外观) 位图缓存画刷 变换…

对二分搜索的理解 Go语言版

二分搜索大家都很熟悉&#xff0c;首先我们先来看看基本框架 func binarySearch(nums []int, target int) int {left, right : 0, ...for ... {mid : left (right-left)/2if nums[mid] target {...} else if nums[mid] < target {left ...} else if nums[mid] > targ…

探索测试开发工程师的通往成功的秘密路径!

「作者说」随着近几年国内IT行业高速发展&#xff0c;对测试工程师的要求也越来越高&#xff0c;其作用也越来越重要&#xff0c;但很多测试工程师也迎来了个人发展的瓶颈&#xff0c;下一步该向哪个方向发展&#xff0c;该如何发展&#xff1f;本文将概述测试工程师的现状及发…

使用MAT分析内存泄漏(mac)

前言 今天主要简单分享下Eclipse的Memory Analyzer在mac下的使用。 一、Mat&#xff08;简称&#xff09;干什么的&#xff1f; 就是分析java内存泄漏的工具。 二、使用步骤 1.下载 mac版的现在也分芯片&#xff0c;别下错了。我这里是M2芯片的&#xff0c;下载的Arch64的。 …

海康运行管理中心 RCE漏洞复现

0x01 产品简介 海康威视是以视频为核心的智能物联网解决方案和大数据服务提供商。海康运行管理中心是一款功能强大、易于使用的安防管理平台&#xff0c;能满足用户对视频监控、报警管理、设备配置和数据统计等方面的需求&#xff0c;帮助用户建立高效、智能的安防系统。 0x02…

tcpdump使用心得

参考原文 https://danielmiessler.com/p/tcpdump/ 几个用例 tcpdump -i eth0 显示eth0网卡当前所有的抓包情况eth0是网卡名&#xff0c;可以通过ifconfig获得&#xff0c;也可以通过 tcpdump -D 显示当前可以监听的网卡 -i 参数表示接口&#xff0c;后跟要监听的网卡 tcpdu…

MySQL 中的锁(三)

8.7. 死锁和空间锁 一般来说&#xff0c;只要有并发和加锁这两种情况的共同加持下&#xff0c;都会有死锁的身影。 死锁的具体成因&#xff0c;借用我们在并发编程中的内容&#xff1a; 8.7.1. 死锁 8.7.1.1. 概念 是指两个或两个以上的进程在执行过程中&#xff0c;由于竞…

二阶龙格塔库积分法求解混沌产生方程(求助)

最近论文中常常接触到激光产生混沌的方程&#xff0c;激光器作为非线性元件&#xff0c;在信息处理中具有非常大的潜力&#xff0c;其中激光产生混沌应用在通信中很有用处。论文中对于模拟数据部分&#xff0c;采用了以下公式来产生混沌&#xff1a;以此公式产生混沌的方法应用…

滴滴打车崩了!全过程

滴滴发布致歉10元补偿券&#xff0c;文末可领取 。 事情发生于 2023年11月27日晚~28日中午&#xff0c;滴滴打车服务出现大面积故障&#xff0c;登上微博热搜。 许多用户在使用滴滴出行时遇到了无法叫车、订单异常等问题&#xff0c;导致大量用户滞留在外&#xff0c;出行受阻…

基于Django+Tensorflow卷积神经网络鸟类识别系统

欢迎大家点赞、收藏、关注、评论啦 &#xff0c;由于篇幅有限&#xff0c;只展示了部分核心代码。 文章目录 一项目简介系统概述系统功能核心技术系统架构系统优势 二、功能三、系统四. 总结  总结 一项目简介 介绍一个基于DjangoTensorflow卷积神经网络鸟类识别系统是一个非…