开启pulsar自动启动,开启broker与bookie自启与自检功能_pulsar bookie-程序员宅基地

技术标签: linux  自动启动  broker  bookie  脚本控制  pulsar  

1. Broker

添加文件:
vim /usr/lib/systemd/system/pulsar.broker.service

内容:
[Unit]
Description=Pulsar Broker
After=network.target

[Service]
ExecStart=/opt/apache-pulsar-2.3.0/bin/pulsar broker
WorkingDirectory=/opt/apache-pulsar-2.3.0
RestartSec=1s
Restart=on-failure
Type=simple

[Install]
WantedBy=multi-user.target

启动命令
systemctl start pulsar.broker.service
systemctl stop pulsar.broker.service

2. bookie(修改这个之前最好关闭自动拷贝功能,)


关闭
bookkeeper shell autorecovery -disable
开启
bin/bookkeeper shell autorecovery -enable

添加文件:
vim /usr/lib/systemd/system/bookkeeper.service

[Unit]
Description=BookKeeper
After=network.target

[Service]
ExecStart=/opt/apache-pulsar-2.3.0/bin/pulsar bookie
WorkingDirectory=/opt/apache-pulsar-2.3.0
RestartSec=1s
Restart=on-failure
Type=simple

[Install]
WantedBy=multi-user.target

启动命令
systemctl start bookkeeper.service
systemctl stop bookkeeper.service

3. 脚本控制broker自启动

broker
启动命令
nohup ./broker_self_start.sh > /tmp/pulsar_broker.log 2>&1 &

broker_self_start.sh
脚本文件
#!/bin/sh
while true
do
sh /etc/profile
time=$(date “+%Y-%m-%d %H:%M:%S”)
echo t i m e p s − e f ∣ g r e p " P u l s a r B r o k e r S t a r t e r " ∣ g r e p − v " g r e p " i f [ " time ps -ef | grep "PulsarBrokerStarter" |grep -v "grep" if [ " timepsefgrep"PulsarBrokerStarter"grepv"grep"if["?" -eq 1 ]
then
pulsar-daemon start broker
echo “process has been restarted!”
else
echo “process already started”
fi
sleep 60
done

bookie

启动命令
nohup ./bookie_self_start.sh > /tmp/pulsar_bookie.log 2>&1 &

bookie_self_start.sh
脚本文件
#!/bin/sh
while true
do
sh /etc/profile
time=$(date “+%Y-%m-%d %H:%M:%S”)
echo t i m e p s − e f ∣ g r e p " B o o k i e S e r v e r " ∣ g r e p − v " g r e p " i f [ " time ps -ef | grep "BookieServer" |grep -v "grep" if [ " timepsefgrep"BookieServer"grepv"grep"if["?" -eq 1 ]
then
pulsar-daemon start bookie
echo “process has been restarted!”
else
echo “process already started”
fi
sleep 60
done

4. 脚本每日清除log以及重启控制脚本

添加定时执行任务

crontab -e
#添加 每日00:30执行
30 0 * * * /opt/shellExecute/pulsar.sh

pulsar.sh

#!/bin/bash
sh /etc/profile
cd /opt/shellExecute
#broker 的每日启动
ps -ef | grep “pulsar_self_start.sh” |grep -v “grep”
if [ "KaTeX parse error: Expected 'EOF', got '&' at position 92: …r_broker.log 2>&̲1 & else proces…(ps x | grep $process | grep -v grep | awk ‘{print $1}’)
echo $pid
pkill -f pulsar_self_start.sh
rm -f /tmp/pulsar_broker.log
nohup ./pulsar_self_start.sh > /tmp/pulsar_broker.log 2>&1 &
fi

#bookie 的每日启动
ps -ef | grep “bookie_self_start.sh” |grep -v “grep”
if [ "KaTeX parse error: Expected 'EOF', got '&' at position 92: …r_bookie.log 2>&̲1 & else proces…(ps x | grep $process | grep -v grep | awk ‘{print $1}’)
echo $pid
pkill -f bookie_self_start.sh
rm -f /tmp/pulsar_bookie.log
nohup ./bookie_self_start.sh > /tmp/pulsar_bookie.log 2>&1 &
fi

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_43832846/article/details/88716516

智能推荐

SimpleHotUpdate使用技巧(UE5智能热更新插件)_ue5 打补丁-程序员宅基地

文章浏览阅读2k次。作者:人宅目录简介目前支持的功能1.界面认识1.1 加载SimpleHotUpdate插件1.2 OSS服务器配置1.3 热更新的服务器文件路径1.4 客户端热更后的安装补丁设置1.5 主版本和额外版本1.6 版本号1,7 关于打包的设置描述1.8 RSA加密1-9 菜单配置表按钮介绍1-10 HTTP服务器界面认识1-11 配置HTTP服务器的服务器1-12 HTTP服务器脚本2 上传补丁和加载补丁方法。2.1 补丁上传2.2 客户端安装策略2.3 生..._ue5 打补丁

微信小程序之 带参数跳转页面实例(传参及接收参数)_小程序页面传参案例,小松菜-程序员宅基地

文章浏览阅读1w次,点赞10次,收藏21次。带参数跳转页面目的:实现页面A带参跳转页面B,并在页面B中获取到相应的参数A页面--------获取id、name值并跳转页面// demo.jsgotoB() { let project_id = e.target.dataset.id; let project_name = this.data.userName; wx.navigateTo({ url: './add/add?id=' + project_id + '&name=' + project__小程序页面传参案例,小松菜

GEE随记(五):研究区平均温度变化曲线_gee中进行温度的趋势分析-程序员宅基地

文章浏览阅读496次。GEE生成研究区域一年内平均温度变化图_gee中进行温度的趋势分析

Jenkins自动化打包脚本_jenkins 自动打包 脚本在package中咋写-程序员宅基地

文章浏览阅读1k次。jenkins可以设置定时任务打包,也已手动点按钮打包,还可以通过执行http请求打包,今天我们就通过shell脚本,通过curl命令进行jenkins打包。_jenkins 自动打包 脚本在package中咋写

基于Apache ShardingSphere打造分布式数据库_shardingshere centos搭建-程序员宅基地

文章浏览阅读1.6k次,点赞3次,收藏3次。张亮京东数科数据研发负责人Apache孵化项目ShardingSphere负责人是写第一行代码的人,可以说是创始人京东数科分布式事务中间件JDTX负责人技术书籍 《未来架构——从服务化到云原生》作者在2019年用闲暇时间写的目录简介分布式数据库核心功能做shardingshpere的指导思想ShardingSphere的实现与规划目前ShardingShpere的状..._shardingshere centos搭建

如何查看cudnn当前版本_Linux上查看已安装的CUDA和cuDNN版本号-程序员宅基地

文章浏览阅读3.9k次,点赞3次,收藏7次。做AI开发时,经常需要用到github上的各种代码,但是这些代码可能需要不同版本的AI开发框架和不同版本的CUDA、cuDNN才能跑通,于是我们的机器上可能要安装多个版本的CUDA和cuDNN,那么如何查看当前机器上已安装的CUDA和cuDNN呢?1. 查看CUDA版本cuda默认安装在/usr/local目录,可以使用ls -l /usr/local | grep cuda查看该目录下有哪些cu..._linux cudnn查看版本 csdn

随便推点

Python基础——常用操作符_≥是操作符吗-程序员宅基地

文章浏览阅读1.4k次。文章目录算数操作符算数操作符Python的算数操作符大部分和我们理解的一样,但尤其要注意一些特别的操作符。一般常用的操作符有:+−∗/%∗∗// +\quad -\quad *\quad /\quad \%\quad **\quad //\quad+−∗/%∗∗//前四个不用过多介绍了,加减乘除。此外,Python和其他大多数编程语言一样,可以简化写法。例如:a = a+1 可以写成 a += 1 等。..._≥是操作符吗

pandas--DataFrame基本操作-重置索引-loc及iloc_数据处理和分析删除dataframe中重复的数据记录。重置索引,使索引重新按顺序依次编-程序员宅基地

文章浏览阅读1.8k次。DataFrameDataFrame介绍DataFrame表示的是矩阵的数据表,它包含已排序的列集合,每一列可以是不同的值类型(数值,字符串,布尔值)。在DataFrame中,数据被存储为一个以上的二维块。DataFrame创建pd.DataFrame(data=None,index=None,columns=None,dtype=None,copy=False)• data:创建数组的数据,可为ndarray, dict• index:指定索引• dtype:数组数据类型• copy:是_数据处理和分析删除dataframe中重复的数据记录。重置索引,使索引重新按顺序依次编

京淘Day16-程序员宅基地

文章浏览阅读125次。1.跨域1.1 跨域测试1.1.1 JT-MANAGE后端测试1.页面结构<!DOCTYPE html><html><head><meta charset="UTF-8"><title>测试JSON跨域问题</title><script type="text/javascript" src="http://manage.jt.com/js/jquery-easyui-1.4.1/jquery.min.js">

Whale帷幄 - 企业数字化解决方案服务商 数字化方案提供商-程序员宅基地

文章浏览阅读184次。Whale 帷幄是国内专业的全域数字化营销运营平台。自 2017 年成立至今,Whale 帷幄深耕新零售、新消费、DTC 及新锐品牌领域,以“让品牌更懂客户”为使命,致力于通过人工智能 (AI), 大规模物联网络 (IoT) 和数据模型 (Data) 的关键技术创新,为面向未来的零售品牌提供数据驱动、协作优先、简单易部署的品牌全域营销运营平台及数字化转型解决方案。凭借多年来沉淀的大量行业最佳实践,Whale 帷幄前瞻性地打造了一套具备「线上线下」全域整合能力的闭环营销运营体系,旨在赋能零售品牌可持续化的_whale帷幄

latex 参考文献显示问号_LaTeX入门(1)-程序员宅基地

文章浏览阅读1.4k次。又是一年的论文季,作为数学系的秃鹫,只会用word排版论文是远远不够的,接下来我将这几天的学习收获分享给大家,也是对自己实战能力的一种考验,这篇文章基本不会告诉你们LaTeX和word相比的各种优势,大家可以参考网上的其他说法,我只会告诉你们,用LaTeX就完事了!LaTeX抛弃了word中传统的“所见即所得”的思想,它不注重文章的排版,样式,而是让作者更加专注于自己所写文章的内容、层次结构,而且..._latex插入参考文献后为问好

【毕业设计】基于SSM的OA办公管理系统的设计与实现 -java web_基于xx技术的某公司oa人事管理系统设计和实现-程序员宅基地

文章浏览阅读945次。Hi,同学们好呀,学长今天带大家复盘一个学长帮往届同学做的一个毕业作品基于Java web的OA系统的设计与实现办公自动化简称为OA(Office Automation)是集计算机科学、通讯技术、系统科学、行为科学为一体的综合性技术。现代的办公自动化系统采用的是Internet/Intranet技术,基于工作流的概念,使得企业内部的员工能够方便快捷地共享信息,高效地协同工作;改变传统复杂、低效的手工办公方式,以实现迅速、全方位的信息采集和信息处理,为企业的管理和决策提供科学的依据。_基于xx技术的某公司oa人事管理系统设计和实现