公司服务器中的kafka消息中间件挂了,我是如何修复的?

今天的公司的system系统服务在运行过程中,提示连接不上kafuka的消息中间件。但是负责kafka的同事已经离职了,询问公司开发也不知道如何处理,我是如何重启kafka消息中间件使system系统服务正常运行?

在这里插入图片描述

在这里插入图片描述

查看kafka的安装位置

在下面的尝试过程中成功找到kafka的资源包
在这里插入图片描述
简单查看一下kafka的配置信息
在这里插入图片描述
在查看配置信息的过程中发现确实地址也对应上就是当时服务报错的IP地址
在这里插入图片描述

查看服务器中Java编译器的安装版本信息

在这里插入图片描述

查看zookeeper服务的运行情况

由于Kafka 使用 Zookeeper 来管理集群的状态,因此在重新启动 Kafka 之前,我需要先确定一下Zookeeper服务是否正常,如果Zookeeper服务也挂了,那么我需要在启动kafka服务之前先启动好Zookeeper服务。

查看这边信息可以知道Zookeeper服务启动正常

在这里插入图片描述

确认一下kafka服务是否正常

从下面的信息可以查出kafka服务果然挂掉了,下面的信息还是只出现了Zookeeper服务的详细日志信息
在这里插入图片描述

启动kafka服务

首先需要在kafka的文件夹下执行下图中的命令

bin/kafka-server-start.sh config/server.properties

在这里插入图片描述
但是使用上述命令启动kafka,服务会随着你的标签页关闭导致服务关闭,因此需要采用后台或者系统服务的方式进行。
这里我采用了 ’nohup‘ 命令

nohup(“no hang up”)命令可以用来运行一个命令,并忽略所有挂断(hangup)信号。这允许程序在关闭终端后继续运行。使用方法如下:

下面这个命令对应的是服务器中的kafka安装地址,你要是使用的话需要替换成自己对应机器的kafka地址。

nohup /opt/kafka/kafka_2.12-3.1.2/bin/kafka-server-start.sh /opt/kafka/kafka_2.12-3.1.2/config/server.properties > /opt/kafka/kafka_2.12-3.1.2/logs/kafka.log 2>&1 &

使用后台方式启动之后,kafka服务就会在后台运行不会因为你关闭标签页而导致服务的关闭。
在这里插入图片描述

查看服务的运行状况

可以看到日志信息明显变多了因为kafka服务启动了
在这里插入图片描述
查看system服务的控制台日志也不报错了
在这里插入图片描述
在这里插入图片描述

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

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

相关文章

Java基础:设计模式之原型模式

原型模式是一种创建型设计模式,它允许我们通过复制现有的对象来创建新的对象,而不是每次都通过构造函数新建。这种模式适用于那些创建新对象成本较高或者构造过程复杂的情况。在原型模式中,一个对象通过实现Cloneable接口并重写其clone()方法…

WPF —— MVVM架构

1 什么是MVVM? MVVM是一种软件架构模式,它将应用程序分为三个层次 model(数据模型),view(视图),viewmodel(视图模型) model:表示应用程序当中数…

什么是RabbitMQ,RabbitMQ基本概念,RabbitMQ的使用场景

目录 面试官:什么是RabbitMQ,RabbitMQ的使用场景什么是RabbitMQ?RabbitMQ基本概念RabbitMQ的使用场景举例该文章专注于面试,面试只要回答关键点即可,不需要对框架有非常深入的回答,如果你想应付面试,是足够了,抓住关键点 面试官:什么是RabbitMQ,RabbitMQ的使用场景 …

SpringCloud之Feign集成Ribbon

Feign定义【可跳过】 Spring Cloud Feign是一个声明式的伪Http客户端,它使得写Http客户端变得更简单。其英文表意为“假装,伪装,变形”,是一个http请求调用的轻量级框架,可以以Java接口注解的方式调用Http请求&#x…

jmeter固定定时器,生效是在请求发送前还是发送后

一、结论 先说结果,是生效在请求发送前 二、背景 在压测流程的时候,生成订单后紧接着调订单查询接口,查询不到,报错率还挺高的,原因肯定是主从延迟,但是DBA非说延时1s内是正常的,在CPU耗用在40%以内的情…

IDM下载器_Internet Download Manager 6.42.7

网盘下载 IDM下载器是一款针对互联网所打造的下载管理器。IDM下载器能将下载速度提高5倍,恢复因丢失的连接,网络问题,计算机关闭或意外断电而重新启动中断或中断的下载。IDM下载器还可支持所有流行的浏览器,以使用独特的“高级浏…

【打工日常】云原生之部署私有化个人工作云盘

一、FileGator介绍1.FileGator简介FileGator是一个免费开源自托管的Web应用程序,用于管理文件和文件夹,部署在自己的服务器上,解放笔记本的压力,随时随地的能看到自己的文件,并且可以共享,方便团队的协作,更有利于个人工作的开展。2.FileGator功能管理本地存储库文件夹中…

视频改字祝福 豪车装X系统源码uniapp前端源码

内容目录 一、详细介绍二、效果展示1.部分代码2.效果图展示 三、学习资料下载 一、详细介绍 uniapp视频改字祝福 豪车装X系统源码 全开源。 创意无限!AI视频改字祝福,豪车装X系统源码开源,打造个性化祝福视频不再难! 想要为你的…

RealSenseSR300工程环境配置说明

新建目录结构如下: output:存储可执行文件.exe等src:存储源码.cpp .h等3rdparty:存储第三方库 opencv等 其中将源码按照main及其相关文件分为以下三类 vs2015许可证到期后先激活,激活码很多网上有,如:HMGNV-WCYXV-X7G9W-YCX63…

开发Chrome插件入门

开发Chrome插件(也称为Chrome扩展)是一个相对直接的过程,尤其对于已经熟悉HTML、CSS、JavaScript的前端开发者而言。以下是开发Chrome插件的基本步骤和示例: 1. 准备工作 首先,确保你有一个适合开发的环境。通常这意…

2024.4.25

#include <iostream> #include <iomanip> using namespace std; class Person{const string name;int age;char sex; public:Person(const string name):name(name){cout << "第一个Person构造函数" << endl;}Person():name("zhangsan&…

java语言基础面试题(一)

面试题1&#xff1a;简述Java的主要特性。 回答&#xff1a;Java的主要特性包括面向对象、跨平台性&#xff08;通过JVM实现&#xff09;、自动内存管理&#xff08;垃圾回收机制&#xff09;、丰富的API和安全性高。 面试题2&#xff1a;解释Java中的多态性。 回答&#xf…

3.7设计模式——Observer 观察者模式(行为型)

意图 定义对象间的一种一对多的依赖关系&#xff0c;当一个对象的状态发生改变时&#xff0c;所有依赖于他的对象都得到通知并被自动更新。 结构 Subject&#xff08;目标&#xff09;知道它的观察者&#xff0c;可以有任意多个观察者观察同一个目标&#xff0c;提供注册和删…

快速入门基础控制台API

目录 一、什么是win32API 二、API基础函数介绍 2.1控制台基础命令 2.1.1标题修改 2.1.2长宽修改 2.1.3坐标 2.2GetStdHandle 2.3GetConsoleCursorInfo 2.4SetConsoleCursorInfo 2.5SetConsoleCursorPosition 2.6GetAsyncKeyState 三、API函数综合应用 3.1设置光标…

C语言案例——输出 Fibonacci 数列(斐波那契数列)的前 40 项

目录 斐波那契数列待续、更新中 斐波那契数列 输出 Fibonacci 数列&#xff08;斐波那契数列&#xff09;的前 40 项 #include <stdio.h> void main() {int a[40] {1,1};int i;printf( "%12d%12d",a[0],a[1]);for(i2; i<40; i){a[i]a[i-1]a[i-2];printf( &q…

IDEA-关于idea在import类时,代码报红的解决方法,找不到包

关于idea在import类时&#xff0c;代码报红的解决方法_idea import报红-CSDN博客

软件企业质量保证的基石――QA,QC的良性协作

软件企业质量保证的基石――QA、QC的良性协作 国内的软件产业发展了20多年的时间&#xff0c;已经由个人英雄时代步入到中、小团队协作时代。相信不久的将来&#xff0c;国内一定会出现航母级的软件企业&#xff0c;那时候我们会迎来集团军作战的时代。不同的时代表明软件规模…

[svelte]组件怎么进行状态共享

前面提到的svelte stores是一种用于管理应用程序状态的机制&#xff0c;它可以在不同组件之间共享状态&#xff0c;但就可能会有这样子的疑问&#xff0c;难道一定要通过stores来传递属性的状态吗 Props&#xff08;属性&#xff09; 最简单的方法是通过将状态作为属性传递给子…

OceanBase 分布式数据库【信创/国产化】- OceanBase 概述

本心、输入输出、结果 文章目录 OceanBase 分布式数据库【信创/国产化】- OceanBase 概述前言OceanBase 数据更新架构高可用高兼容水平扩展低成本实时 HTAP安全可靠OceanBase 分布式数据库【信创/国产化】- OceanBase 概述 编辑 | 简简单单 Online zuozuo 地址 | https://blog.…

[C/C++] -- C++11相关内容

一&#xff1a;声明 auto: auto 是 C11 引入的一个关键字&#xff0c;用于自动推断变量的类型。通过使用 auto&#xff0c;编译器可以根据变量的初始化表达式推断其类型&#xff0c;从而减少代码中的重复冗长的类型声明。 简化模板声明&#xff1a; for(auto p vec.begin(…