品牌 资讯 搭配 材料 时尚 热点 行业 首饰 玉石 行情

世界最新:pulsar集群部署

2023-03-31 04:08:57 来源:腾讯云

Pulsar是一个分布式的、高可用的、多租户的消息系统,由Apache Pulsar项目开发和维护。Pulsar可以处理大规模数据集,同时提供多种数据持久化选项和各种API,方便开发人员构建基于Pulsar的应用程序。本文将介绍如何在Linux环境下部署Pulsar集群。

系统要求 在部署Pulsar集群之前,您需要满足以下系统要求:

Linux系统(例如CentOS、Ubuntu等)Java 8或更高版本至少2个主机用于搭建Pulsar集群

下载和安装Pulsar 在开始部署Pulsar之前,您需要下载Pulsar的二进制文件并解压缩到一个目录中。您可以从Pulsar官方网站下载最新版本的二进制文件。


(资料图)

假设您已经将Pulsar的二进制文件解压缩到了/opt/pulsar目录中。在每个Pulsar节点上,您需要设置PULSAR_HOME环境变量:

export PULSAR_HOME=/opt/pulsar

您还需要将$PULSAR_HOME/bin添加到$PATH环境变量中,以便您可以方便地使用Pulsar的命令行工具:

export PATH=$PATH:$PULSAR_HOME/bin

配置ZooKeeper Pulsar需要使用ZooKeeper作为其元数据存储和协调服务。您需要在每个Pulsar节点上安装和配置ZooKeeper。

首先,您需要从ZooKeeper官方网站下载最新版本的二进制文件。然后,将ZooKeeper的二进制文件解压缩到一个目录中(例如/opt/zookeeper),并在每个Pulsar节点上设置ZOOKEEPER_HOME环境变量:

export ZOOKEEPER_HOME=/opt/zookeeper

您还需要将$ZOOKEEPER_HOME/bin添加到$PATH环境变量中:

export PATH=$PATH:$ZOOKEEPER_HOME/bin

接下来,您需要在每个Pulsar节点上创建一个ZooKeeper配置文件(例如/opt/zookeeper/conf/zoo.cfg),并在其中添加以下配置:

tickTime=2000initLimit=10syncLimit=5dataDir=/var/lib/zookeeperclientPort=2181

在上面的配置中,tickTime表示ZooKeeper使用的基本时间单位(以毫秒为单位),initLimit表示ZooKeeper在启动过程中等待Follower节点同步的最大时间(以tick为单位),syncLimit表示Leader节点与Follower节点之间的最大时间差(以tick为单位),dataDir表示ZooKeeper保存其快照和日志的目录,clientPort表示ZooKeeper客户端连接的端口。

您还需要在每个Pulsar节点上创建一个myid文件,以指定该节点在ZooKeeper集群中的唯一标识。您可以将任意数字作为myid文件的内容,例如在节点1上创建一个名为myid的文件,并将内容设置为1:

echo "1" > /var/lib/zookeeper/myid

对于节点2和节点3,您需要创建相应的myid文件,并将内容分别设置为2和3。

最后,您需要启动ZooKeeper服务。在节点1上,可以使用以下命令启动ZooKeeper服务:

zkServer.sh start

在节点2和节点3上,也需要启动ZooKeeper服务。

部署Pulsar集群 在完成ZooKeeper的配置之后,您可以开始部署Pulsar集群了。在每个Pulsar节点上,您需要创建一个broker.conf文件,以指定Pulsar Broker的配置。以下是一个示例broker.conf文件:

zookeeperServers=zk1:2181,zk2:2181,zk3:2181configurationStoreServers=zk1:2181,zk2:2181,zk3:2181brokerServicePort=6650webServicePort=8080

在上面的配置中,zookeeperServersconfigurationStoreServers表示Pulsar Broker应该连接的ZooKeeper服务器的列表。brokerServicePort表示Pulsar Broker应该使用的端口,webServicePort表示Pulsar Web服务应该使用的端口。

在每个Pulsar节点上,您可以使用以下命令启动Pulsar Broker:

bin/pulsar broker

此命令将启动Pulsar Broker,并将其连接到ZooKeeper集群。

验证Pulsar集群 在完成Pulsar集群的部署之后,您可以使用以下命令验证Pulsar集群是否正常工作:

bin/pulsar-admin brokers list

此命令将列出Pulsar集群中所有可用的Broker节点。

您还可以使用以下命令创建一个主题并发布一些消息:

bin/pulsar-admin topics create my-topicbin/pulsar-client produce my-topic --messages "Hello, World!"

在这些命令中,pulsar-adminpulsar-client是Pulsar命令行工具。topics create命令用于创建一个新的主题,pulsar-client produce命令用于发布消息到指定的主题。

您可以使用以下命令消费发布的消息:

bin/pulsar-client consume my-topic

此命令将从my-topic主题消费已发布的消息。

标签:

(责任编辑:)

相关文章

世界最新:pulsar集群部署

​下载和安装Pulsar在开始部署Pulsar之前,您需要下载Pulsar的二进制文件并解压缩到一个目录中。您可以从Pulsar官方网站下载最新版本的二进制文件

2023-03-31 04:08:57

世界观焦点:嫦娥五号发现月球“水库”,储水量可达2700亿吨

​IT之家3月30日消息,月球上有没有水?如果有,藏在哪里?嫦娥五号带回的月球样品给我们提供了线索。图源Pixabay据IT之家了解,在太空中,陨石

2023-03-30 23:52:18

第三届儒商大会集中对外推介253个合作项目

​中国山东网-感知山东3月30日讯(记者张敏敏)3月30日,山东省政府新闻办召开新闻发布会,介绍第三届儒商大会的组织实施情况和主要成果。记者从发

2023-03-30 21:51:32

海信家电(00921)拟续聘信永中和会计师事务所

​智通财经APP讯海信家电00092100921发布公告公司董事会会议审议及批准《关于续聘信永中和会计师事务所特殊普通合伙担任公司2023年度审计机构的

2023-03-30 21:01:25

经营现金流转负,背靠淘宝的跨境电商物流供应商泛远国际赴港上市|世界速看料

​泛远国际如想要在这个相对分散的市场上分得更大蛋糕,仍需思考如何应对来自如中联航运、德威、燕文等对手的竞争。

2023-03-30 18:57:44

大宗交易:利民股份成交537.6万元,折价9.49%(03-30)

​2023年3月30日,利民股份发生1笔大宗交易,总成交60万股,成交金额537 6万元,成交价8 96元,折价9 49%。

2023-03-30 17:45:13

qq头像的尺寸是多大

​微信头像大小:头像尺寸、大小:最好正方形200*200或300*300宽、也可自行调整尺寸,高相等即可。头像

2023-03-30 16:59:29

世界快讯:二次入职试用期约定

​一、二次入职试用期约定二次入职试用期不可以约定试用期。同一用人单位与同一劳动者只能约定一次试用期。试用期包含在劳动合同期

2023-03-30 16:13:32

环球快讯:警校社三方联动,成都三十三中扎实做好禁毒宣传教育

​为切实加大禁毒宣传力度,驷马桥街道联合驷马桥派出所于2023年3月29日在成都市第三十三中学校开展了“毒品一日不绝、禁毒一刻不止”禁毒宣...

2023-03-30 15:34:41

世界信息:花开正当时!来曲水园赴一场海棠花的盛宴吧~

​”阳春三月,春暖花开,青浦景色美不胜收,在曲水园内垂丝海棠花正在盛开,成片的垂丝海棠就开得相当好看,让人流连忘返。市民张阿姨告诉记...

2023-03-30 14:43:49

沙发套怎么轻松套上(沙发套怎么轻松套上的)

​沙发是家里休息的地方,通常为了保证沙发的干净,我们可以套上沙发套,这样清洗的时候直接拆洗沙发套即可,所以我们买沙发套最好选择那种可拆

2023-03-30 13:33:06

长沙一房产中介诈骗8人共300余万元!|环球观速讯

​长沙一房产中介诈骗8人共300余万元!

2023-03-30 12:12:18

马叉虫魔性表情包_马叉虫

​1、骚[sāo][sǎo][字义]:[sāo]1 动乱,扰乱,不安定:~乱。2、~扰。3、~动。4、2 忧愁:“离~

2023-03-30 11:33:16

全球热点!本周五晚油价将迎来大跌!预计每升汽油优惠3毛3,要加油的再等等

​另外,按照我们湖南地区目前的汽油价格来看,92号汽油的价格是7 66元 升,95号汽油是8 14元 升,而98号汽油的价格则为8 94元 升。尤其是那些需

2023-03-30 10:48:34

创业板公司融资余额减少2.50亿元 13股遭减仓超10%

​创业板股最新融资余额为2033 81亿元,环比减少2 50亿元,25只股融资余额环比增长超10%,融资余额环比降幅超10%的有13只。

2023-03-30 09:56:34

游客被困高海拔雪山上 四川阿坝消防成功救援

​人民网成都3月29日电日前,四川省阿坝州消防救援支队指挥中心接到游客报警称,自己驾车被大雪困在小金县汗牛乡大哇梁子,车辆已熄火,需要救援

2023-03-30 09:15:56

大场面!海军春季入伍新兵开训_今日聚焦

​春风催奋进,练兵正当时随着新兵入营工作陆续结束海军各新兵训练基地组织开训动员大会火热的新训生活正式开启开训“第一课”刺杀操、战术动...

2023-03-30 08:42:25

为什么会阳痿?你得从这4个方面找原因!

​那么导致阳痿的原因主要有哪些呢?1、自身疾病有一些男性本身就患有一些泌尿生殖系统疾病,比如前列腺炎、前列腺增生、附睾炎等疾病,都会影响

2023-03-30 07:19:53

cad打印jpg像素设置a3_cad打印jpg像素设置

​1、方法 步骤打开CAD图形,选择打印(Ctrl+P组合键),打开打印窗口:2、在打印机 绘图仪名称中。2、选择Publ

2023-03-30 05:06:35

星球大战:旧共和国在主要更新中升级到64位 环球新消息

​BioWare的免费MMORPG星球大战:旧共和国刚刚发布了一个重大更新,将游戏升级到64位客户端,这一飞跃在性能和内容方面对游戏的未来产生了严重影

2023-03-30 01:00:53

当前热讯:成都常住人口增量超京沪渝,四川“城市断层”如何打破?

​原创西窗搜狐城市在“两千万+”常住人口城市中,成都落后重庆上海北京处于最后一位。不过去年成都录得最多人口增量:统计公

2023-03-29 22:25:56

青海玉树消防高原砺剑 零下15度开展地震实战演练_焦点信息

​玉树消防供图图为地震实战拉动现场,参演人员正在进行车辆事故救援项目。玉树消防供图图为地震实战拉动现场,参演人员正在进行顶撑救援项目。

2023-03-29 21:14:57

每日快讯!康龙化成(03759):楼小强的28.5万股质押股份进行延期购回

​智通财经APP讯康龙化成30075903759公布康龙化成北京新药技术股份有限公司近日接到公司实际控制人之一楼小强的函告获悉楼小强根据其资金需求情

2023-03-29 20:09:12

【环球财经】德国消费者信心继续复苏 但势头减弱|每日快看

​德国4月Gfk消费者信心指数-29 5点,经调整后环比升高1 1点,升幅弱于3月的3点,为连续第六个月环比上升。

2023-03-29 18:47:23

快看点丨一类高层住宅规范_国家标准规定的一类高层住宅建筑

​1、一类高层建筑分为两种:一、居住建筑十九层及十九层以上的住宅。2、二、公共建筑1 医院2 高级旅馆3 建筑高度超过50

2023-03-29 17:56:08

每日聚焦:五一放假安排2021 五一国际劳动节的由来

​五一放假安排20212021五一劳动节放假多少天2021五一劳动节放假安排:5月1日-5月3日放假,共三天。2021五一时间是2021年5月1日,星期六,农历四

2023-03-29 17:10:24

当前关注:为什么说天下未乱蜀先乱(天下未乱蜀先乱)

​1、原文是:“天下未乱蜀先乱,天下已治蜀后治。2、”这句话最早见于明末清初人欧阳直公的《蜀警录》,其中就是对明末流寇张献忠这个杀人魔...

2023-03-29 16:26:44

环球短讯!【银河农产品0328】在产存栏蛋鸡量较低,现货价格相对强势!今日重点关注:鸡肉、粕类

​早评  农产品  鸡肉、粕类  刘倩楠  1、集装箱运价:3 24日当周SCFI集装箱运价指数908 35,环比-0 2%,同比-79 5%。其中,上海-美西集装箱

2023-03-29 15:35:53

【天天聚看点】炎症性肠病患者这类水果建议少食用!来看仁济医院专家的最新研究成果

​近日,上海交通大学医学院附属仁济医院检验科李敏课题组在《胃肠病学》(Gastroenterology)上在线发表了题为《宿主山梨醇和细菌山梨醇利用促

2023-03-29 14:52:36

平谷法院开展安全教育日特色“普法大集”进校园活动

​潘俊强3月27日,在全国中小学生安全教育日当天,平谷法院首次将“普法大集”开到了平谷区校园国家安全宣传教育基地平谷五中。活动以集市摆...

2023-03-29 13:32:18