Pulsar 社区周报 | No.2024-03-29 Pulsar 全面拥抱 OpenTelemetry 标准

各位热爱 Pulsar 的小伙伴们,Pulsar 社区周报更新啦!这里将记录 Pulsar 社区每周的重要更新,周五发布。

Pulsar 逐步拥抱 OpenTelemetry 标准

OpenTelemetry 正在迅速成为指标度量的事实标准 API,这将有利于提升指标采集的扩展性,Pulsar 正在也在快速拥抱中。其中 PIP-264[1] 讲述了服务端指标的迁移。本周 Release 的 PIP-342[2] 将在 Pulsar 客户端中支持 OpenTelemetry 指标。

Pulsar Weekly Merge Stars

感谢以下的小伙伴,感谢你们本周为 Apache Pulsar 做的精彩贡献(排名不分先后)

578ea3de3d5a9d015bc529f27bca0485.png
Pulsar Weekly Merge Stars

@Shawyeok,@dependabot[bot],@crossoverJie,@lhotari,@nodece,@jianyun8023,@coderzc,@tmzk1005,@Technoboy-,@BewareMyPower,@liangyepianzhou,@dao-jun,@nicoloboschi,@doug-ba,@hanmz,@poorbarcode,@sherlock-lin,@merlimat

apache/pulsar

fix

  • [fix][test] 解决 ManagedLedgerErrorsTest.recoverAfterZnodeVersionError 的不稳定性问题 [3] @lhotari

  • [fix][broker]修复OpReadEntry.skipCondition NPE问题 [4] @Technoboy-

  • [fix][broker]修复 PersistentTopic 类中的拼写错误 [5] @hanmz

  • [fix][client]修复在按时间戳搜索后的可用消息和读取下一条消息的错误结果 [6] @BewareMyPower

  • [fix][misc]使ConcurrentBitSet线程安全 [7] @lhotari

  • [fix][cli]修复 CmdSinks 类中的拼写错误 [8] @hanmz

  • [fix][broker][branch-2.10]快速修复由于错误的主题名称引起的无限HTTP调用getSubscriptions的问题 [9] @poorbarcode

  • [fix][client]消费者由于在批量消息确认过程中出现竞争条件,导致丢失消息确认。[10] @Shawyeok

  • [fix][broker][branch-2.11]快速修复因错误的主题名称createSubscriptions而导致的无限HTTP调用问题。[11] @poorbarcode

  • [fix] [test]修复不稳定的测试ManagedLedgerTest.testGetNumberOfEntriesInStorage [12] @poorbarcode

  • [fix][broker]修复 ResourceGroup 报告本地使用量 [13] @nodece

  • [fix][ml] Expose ledger 时间戳 [14] @dao-jun

  • [fix][broker]避免在检查未关闭的 ledgers 时出现过期的消息,不要按照Apache Pulsar的 ledgers 关闭时间来解释我的原文。[15] @coderzc

  • [fix] [broker]修复分发器消费者列表与分发器消费者集合不匹配 [16] @poorbarcode

  • [fix] [broker]关闭调度程序,因为调度程序.consumerlList和调度程序.consumerSet之间不匹配导致卡住。[17] @poorbarcode

  • [fix]升级 /pulsar-function-go/examples 中的 google.golang.org/protobuf 版本,从 1.32.0 版本升级至 1.33.0 版本。[18] @dependabot[bot]

  • [fix][broker]dictionary检查光标状态后再将其添加到`waitingCursors`字典中。[19] @Technoboy-

  • [fix][broker]在当前 ledger 关闭后创建新的 ledger [20] @liangyepianzhou

  • [fix][broker]修复 ResourceGroups 的加载修复加载 ResourceGroups [21] @nodece

新特性

  • [improve][misc]升级至Netty 4.1.108和tcnative 2.0.65 [22] @lhotari

  • [improve][broker]优化web界面deleteDynamicConfiguration返回错误消息 [23] @hanmz

  • [improve][cli]PIP-343:在Pulsar函数中使用picocli而不是jcommander [24] @nodece

  • [improve][misc]删除对sun InetAddressCachePolicy的调用 [25] @jianyun8023

  • [improve][misc]包括 Netty 的原生 epoll 库为 arm64。[26] @lhotari

  • [improve][cli]PIP-343: 在pulsar-perf中使用picocli而不是jcommander [27] @crossoverJie

  • [improve][cli]PIP-343:在bin/pulsar中使用picocli而不是jcommander。[28] @nodece

  • [improve] [pip]PIP-344 修正公共API的行为pulsarClient.getPartitionsForTopic(topicName)。[29] @poorbarcode

  • [improve]PIP 342:在Pulsar客户端中支持 OpenTelemetry 指标 [30] @merlimat

others

  • [cleanup][broker]修复 PersistentSubscription 重复实现界面订阅接口 [31] @sherlock-lin

  • [cleanup][cli]integration清理 jcommander 集成 [32] @nodece

apache/bookkeeper

others

  • 改进发布说明生成 [33] @nicoloboschi

  • 问题 4200:修复不稳定的测试 DeferredSyncTest.testForceWillAdvanceLacOnlyUpToLastAcknoledgedWrite [34] @tmzk1005

  • 提升 org.apache.zookeeper:zookeeper 从 3.8.3 到 3.8.4 [35] @dependabot[bot]

  • 升级/site3/website中的1.14.9至1.15.6上的 follow-redirects  [36] @dependabot[bot]

apache/pulsar-client-cpp

others

  • 修正时间戳切换后 hasMessageAvailable 和 readNext 的错误结果 [37] @BewareMyPower

  • 修复CodeQL报告的小问题 [38] @merlimat

apache/pulsar-client-python

others

  • 添加Consumer的consumer_name() API [39] @BewareMyPower

apache/pulsar-helm-chart

others

  • 在values.yaml中默认关闭 functions [40] @lhotari

  • 添加在安装时显示的NOTES.txt文档 [41] @lhotari

  • 保持job.ttl.enabled一致和有效,只在k8s >= 1.23时生效。[42] @lhotari

  • 开始是将 ReleaseIsInstall 固定为可选的初始任务开始时,将 ReleaseIsInstall 设置为可选项的初始作业。[43] @doug-ba

  • keyPulsar-manager 增加现有密钥的支持 [44] @doug-ba

  • 为Apache Pulsar添加使用单独磁盘来存储zookeeper事务日志的能力。[45] @doug-ba

  • 使用 podManagementPolicy OrderedReady 适用于启用 Functions 时的 Broker sts [46] @lhotari

活动新闻

  • 深圳线下 Meetup 倒计时,欢迎加 Pulsar Bot 咨询。

  • 2024 年 5月 14 日:2024 Pulsar 欧洲虚拟峰会[47]

  • 2024 年 7 月 26-28 日:阿帕奇软件基金会亚洲大会(CommunityOverCode Asia 2024)Messaging 专题[48]

联系我们

Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存储分离架构设计,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性。GitHub 地址:http://github.com/apache/pulsar/

83feff021e6b3fe38baf843b724516ac.png
Pulsar 中文社区 Logo(部分)

诚挚邀请您加入 Apache Pulsar 社区,与全球开发者一起学习、分享和成长,共同塑造云原生消息流平台的未来,一起打造更加开放和高效的开源技术生态!

61f066f088f6467862c1e92584d0f4d0.png
Pulsar 进群说明

推荐阅读

往期周报

Pulsar 社区周报 | No.2024.03.22 官网焕然一新:重磅推出 PMC 和 Commiter 名录

Pulsar 社区周报 | No.2024.03.15 LTS 3.0.3 新版发布

Pulsar 社区周报 | No.2024.03.08 Pulsar-Spark Connector 助力实时计算 原创

干货文章

e4c79132df0f360e2f42c36cc12cd590.jpeg Apache Pulsar 为滴滴大数据运维带来了哪些收益?

7e94a0f6558350d1a8b396aecbb1af5a.jpeg技术探究 | 开篇 | 深度探讨:Apache Pulsar 在事件驱动型业务中的应用

b25adf2a8340a831f8283efb3307e37e.jpeg

消息队列20年:腾讯专家沉淀的 MQ 设计精要

参考资料

[1]

PIP-264:https://github.com/apache/pulsar/blob/master/pip/pip-264.md

[2]

PIP-342:https://github.com/apache/pulsar/blob/master/pip/pip-342%20OTel%20client%20metrics%20support.md

[3]

[fix][test] 解决 ManagedLedgerErrorsTest.recoverAfterZnodeVersionError 的不稳定性问题  :https://github.com/apache/pulsar/pull/22368

[4]

[fix][broker]修复OpReadEntry.skipCondition NPE 问题 :https://github.com/apache/pulsar/pull/22367

[5]

[fix][broker]修复 PersistentTopic 类中的拼写错误 :https://github.com/apache/pulsar/pull/22364

[6]

[fix][client]修复在按时间戳搜索后的可用消息和读取下一条消息的错误结果 :https://github.com/apache/pulsar/pull/22363

[7]

[fix][misc]使ConcurrentBitSet线程安全 :https://github.com/apache/pulsar/pull/22361

[8]

[fix][cli]修复 CmdSinks 类中的拼写错误 :https://github.com/apache/pulsar/pull/22358

[9]

[fix][broker][branch-2.10]快速修复由于错误的主题名称引起的无限HTTP调用getSubscriptions的问题 :https://github.com/apache/pulsar/pull/22357

[10]

[fix][client]消费者由于在批量消息确认过程中出现竞争条件,导致丢失消息确认。:https://github.com/apache/pulsar/pull/22353

[11]

[fix][broker][branch-2.11]快速修复因错误的主题名称createSubscriptions而导致的无限HTTP调用问题。:https://github.com/apache/pulsar/pull/22346

[12]

[fix] [test]修复不稳定的测试ManagedLedgerTest.testGetNumberOfEntriesInStorage :https://github.com/apache/pulsar/pull/22344

[13]

[fix][broker]修复 ResourceGroup 报告本地使用量 :https://github.com/apache/pulsar/pull/22340

[14]

[fix][ml] Expose ledger 时间戳 :https://github.com/apache/pulsar/pull/22338

[15]

[fix][broker]避免在检查未关闭的 ledgers 时出现过期的消息,不要按照Apache Pulsar的 ledgers 关闭时间来解释我的原文。:https://github.com/apache/pulsar/pull/22335

[16]

[fix] [broker]修复分发器消费者列表与分发器消费者集合不匹配 :https://github.com/apache/pulsar/pull/22283

[17]

[fix] [broker]关闭调度程序,因为调度程序.consumerlList和调度程序.consumerSet之间不匹配导致卡住。:https://github.com/apache/pulsar/pull/22270

[18]

[fix]升级 /pulsar-function-go/examples 中的 google.golang.org/protobuf 版本,从 1.32.0 版本升级至 1.33.0 版本。:https://github.com/apache/pulsar/pull/22262

[19]

[fix][broker]dictionary检查光标状态后再将其添加到waitingCursors字典中。:https://github.com/apache/pulsar/pull/22191

[20]

[fix][broker]在当前 ledger 关闭后创建新的 ledger :https://github.com/apache/pulsar/pull/22034

[21]

[fix][broker]修复 ResourceGroups 的加载修复加载 ResourceGroups :https://github.com/apache/pulsar/pull/21781

[22]

[improve][misc]升级至Netty 4.1.108和tcnative 2.0.65 :https://github.com/apache/pulsar/pull/22369

[23]

[improve][broker]优化web界面deleteDynamicConfiguration返回错误消息 :https://github.com/apache/pulsar/pull/22356

[24]

[improve][cli]PIP-343:在Pulsar函数中使用picocli而不是jcommander :https://github.com/apache/pulsar/pull/22331

[25]

[improve][misc]删除对sun InetAddressCachePolicy的调用 :https://github.com/apache/pulsar/pull/22329

[26]

[improve][misc]包括 Netty 的原生 epoll 库为 arm64。:https://github.com/apache/pulsar/pull/22319

[27]

[improve][cli]PIP-343: 在pulsar-perf中使用picocli而不是jcommander :https://github.com/apache/pulsar/pull/22303

[28]

[improve][cli]PIP-343:在bin/pulsar中使用picocli而不是jcommander。:https://github.com/apache/pulsar/pull/22288

[29]

[improve] [pip]PIP-344 修正公共API的行为pulsarClient.getPartitionsForTopic(topicName)。:https://github.com/apache/pulsar/pull/22182

[30]

[improve]PIP 342:在Pulsar客户端中支持 OpenTelemetry 指标 :https://github.com/apache/pulsar/pull/22178

[31]

[cleanup][broker]修复 PersistentSubscription 重复实现界面订阅接口 :https://github.com/apache/pulsar/pull/22359

[32]

[cleanup][cli]integration清理 jcommander 集成 :https://github.com/apache/pulsar/pull/22337

[33]

改进发布说明生成 :https://github.com/apache/bookkeeper/pull/4250

[34]

问题 4200:修复不稳定的测试 DeferredSyncTest.testForceWillAdvanceLacOnlyUpToLastAcknoledgedWrite :https://github.com/apache/bookkeeper/pull/4234

[35]

提升 org.apache.zookeeper:zookeeper 从 3.8.3 到 3.8.4 :https://github.com/apache/bookkeeper/pull/4231

[36]

升级/site3/website中的1.14.9至1.15.6上的 follow-redirects  :https://github.com/apache/bookkeeper/pull/4230

[37]

修正时间戳切换后 hasMessageAvailable 和 readNext 的错误结果 :https://github.com/apache/pulsar-client-cpp/pull/422

[38]

修复CodeQL报告的小问题 :https://github.com/apache/pulsar-client-cpp/pull/421

[39]

添加Consumer的consumer_name() API :https://github.com/apache/pulsar-client-python/pull/206

[40]

在values.yaml中默认关闭 functions :https://github.com/apache/pulsar-helm-chart/pull/483

[41]

添加在安装时显示的NOTES.txt文档 :https://github.com/apache/pulsar-helm-chart/pull/482

[42]

保持job.ttl.enabled一致和有效,只在k8s >= 1.23时生效。:https://github.com/apache/pulsar-helm-chart/pull/481

[43]

开始是将 ReleaseIsInstall 固定为可选的初始任务开始时,将 ReleaseIsInstall 设置为可选项的初始作业。:https://github.com/apache/pulsar-helm-chart/pull/480

[44]

keyPulsar-manager 增加现有密钥的支持 :https://github.com/apache/pulsar-helm-chart/pull/478

[45]

为Apache Pulsar添加使用单独磁盘来存储zookeeper事务日志的能力。:https://github.com/apache/pulsar-helm-chart/pull/476

[46]

使用 podManagementPolicy OrderedReady 适用于启用 Functions 时的 Broker sts :https://github.com/apache/pulsar-helm-chart/pull/474

[47]

Pulsar Virtual Summit Europe 2024:https://sessionize.com/pulsar-virtual-summit-europe-2024

[48]

CommunityOverCode Asia 2024 议题征集正式启动!:https://mp.weixin.qq.com/s/byAbsKwC7XofWwxGBiylCw

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

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

相关文章

羊大师解密长期喝羊奶的十大好处

在忙碌而又充满挑战的现代生活中,维持一个健康的生活方式变得越来越重要。羊奶,作为自古以来就被人类广泛消费的一种天然饮品,不仅味道醇厚,而且营养价值丰富。让我们一起探索长期饮用羊奶所带来的十大好处。 丰富的营养成分 羊奶…

Kaggle注册验证码问题(Captcha must be filled out.)

Kaggle注册验证码问题 Captcha must be filled out.使用Edge浏览器 Header Editor 插件安装 下载插件Header Editor 导入重定向脚本 点击扩展插件, 打开Header Editor插件,进行管理 点击导入输入下载链接进行下载或者导入本地json文件(二者任选其一…

你知道吗?NHANES数据也能做孟德尔随机化来验证因果,还发了二区(IF=7.4)

编者 近日,福建医科大学研究团队仅用孟德尔随机化,结合NHANES和GWAS数据库发文二区,验证他汀类药物是糖尿病视网膜病变的危险因素,与各位做个分享! 相信大家都知道,高血糖会导致糖尿病(DM&#…

安全团队需要重点演练的四大威胁

文章目录 前言一、勒索软件攻击二、第三方风险三、内部威胁四、分布式拒绝服务攻击(DDoS)前言 桌面演练(推演)是一种重要的安全演习形式,参演人员利用演练方案、流程图、计算机模拟、视频会议等辅助手段,针对事先假定的演练情景,讨论和推演应急决策及现场处置,从而促使相…

“51媒体”线下活动,媒体线上同步直播的好处,有哪些资源?

传媒如春雨,润物细无声,大家好,我是51媒体网胡老师。 线下活动媒体线上同步直播的好处以及可利用的资源如下: 好处: 扩大影响力:通过媒体线上同步直播,活动可以覆盖更广泛的受众群体&#xff…

37-巩固练习(一)

37-1 if语句等 1、问&#xff1a;输出结果 int main() {int i 0;for (i 0; i < 10; i){if (i 5){printf("%d\n", i);}return 0;} } 答&#xff1a;一直输出5&#xff0c;死循环 解析&#xff1a;i5是赋值语句&#xff0c;不是判断语句&#xff0c;每一次循…

零基础教程:R语言lavaan结构方程模型(SEM)

查看原文>>>最新基于R语言lavaan结构方程模型&#xff08;SEM&#xff09;实践技术应用 基于R语言lavaan程序包&#xff0c;通过理论讲解和实际操作相结合的方式&#xff0c;由浅入深地系统介绍结构方程模型的建立、拟合、评估、筛选和结果展示的全过程。我们筛选大量…

鸿蒙原生应用开发-网络管理HTTP数据请求

一、场景介绍 应用通过HTTP发起一个数据请求&#xff0c;支持常见的GET、POST、OPTIONS、HEAD、PUT、DELETE、TRACE、CONNECT方法。 二、接口说明 HTTP数据请求功能主要由http模块提供。 使用该功能需要申请ohos.permission.INTERNET权限。 涉及的接口如下表&#xff0c;具体的…

分享一个免费的chat工具

用这个神奇的聊天工具&#xff0c;我的生活变得更加便利了。不需要魔法&#xff0c;不需要海外手机号码&#xff0c;来试试吧:Chat8。点击使用: https://guan.chat772.com/#/register?bronk_on1579566

用html写一个贪吃蛇游戏

<!DOCTYPE html> <html> <head><title>贪吃蛇</title><meta charset"UTF-8"><meta name"keywords" content"贪吃蛇"><meta name"Description" content"这是一个初学者用来学习的小…

实现一个Google身份验证代替短信验证

最近才知道公司还在做国外的业务&#xff0c;要实现一个登陆辅助验证系统。咱们国内是用手机短信做验证&#xff0c;当然 这个google身份验证只是一个辅助验证登陆方式。看一下演示 看到了嘛。 手机下载一个谷歌身份验证器就可以 。 谷歌身份验证器&#xff0c;我本身是一个基…

多模态大模型:解析未来智能汽车的新引擎

多模态大模型&#xff1a;解析未来智能汽车的新引擎 1. 多模态大模型简介2. 多模态大模型在智能汽车中的应用2.1 感知与认知2.2 智能驾驶辅助2.3 智能交互 随着人工智能技术的不断进步&#xff0c;智能汽车已经从概念变成了现实&#xff0c;成为了当今科技领域的焦点之一。而在…

#include<初见c语言之指针总结>

第一小节&#xff1a; #include&#xff1c;初见C语言之指针&#xff08;1&#xff09;&#xff1e;-CSDN博客 #add&#xff1c;初见C语言之指针&#xff08;1&#xff09;&#xff1e;-CSDN博客 第二小节&#xff1a; #include&#xff1c;初见c语言之指针…

C++进阶,手把手带你学继承

&#x1fa90;&#x1fa90;&#x1fa90;欢迎来到程序员餐厅&#x1f4ab;&#x1f4ab;&#x1f4ab; 主厨&#xff1a;邪王真眼 主厨的主页&#xff1a;Chef‘s blog 所属专栏&#xff1a;c大冒险 总有光环在陨落&#xff0c;总有新星在闪烁 【本节目标】 1.继…

RAG进阶笔记:RAG进阶

1 查询/索引部分 1.1 层次索引 创建两个索引——一个由摘要组成&#xff0c;另一个由文档块组成分两步进行搜索&#xff1a;首先通过摘要过滤出相关文档&#xff0c;接着只在这个相关群体内进行搜索 1.2 假设性问题 让LLM为每个块生成一个假设性问题&#xff0c;并将这些问…

【ENSP】交换机和交换机之间实现静态路由

1.概念 三层交换机只能在Vlanif逻辑口配置iP地址 2.实现方法 交换机允许对应vlan通行&#xff0c;配置vlanif的ip地址&#xff0c;做静态路由 3.静态路由配置方法 ip route-static 目的网段 子网掩码 下一跳设备 LSW1三层交换机配置 u t m sys vlan batch 10 20 …

用Python实现办公自动化(自动化处理Excel工作簿)

自动化处理Excel工作簿 &#xff08;一&#xff09;批量生产产品出货清单 以“出货统计表”为例&#xff0c; 需求&#xff1a;将出货记录按照出货日期分类整理成多张出货清单 “出货统计表数据案例” “产品出货清单模板” 1.提取出货统计表的数据 “Python程序代码” # 使用…

网络安全入门 5 天速成教程_ WEB 安全渗透攻防技术

前言 随着 Web 技术发展越来越成熟&#xff0c;而非 Web 服务越来越少的暴露在互联网上&#xff0c;现在互联网安全主要指的是 Web 安全。 为了自身不“裸奔”在大数据里&#xff0c;渐渐开始学习 Web 安全&#xff0c;在学习 Web 安全的过程中&#xff0c;发现很大一部分知识…

分文件编程——Makefile

1.分文件编程 1.1源文件&#xff1a; .c结尾的文件 包含main函数的.c 包含子函数的.c 1.2头文件&#xff1a; .h结尾的文件 文件包含 头文件、宏定义、typedef、结构体、共用体、枚举、函数声明… 调用时用#include"xx.h" #include< >与#include " &q…

对DataFrame中的缺失值采用插值实现缺失值处理interpolate()

【小白从小学Python、C、Java】 【计算机等考500强证书考研】 【Python-数据分析】 对DataFrame中的缺失值 采用插值实现缺失值处理 interpolate() [太阳]选择题 以下代码的输出结果中正确的是? import pandas as pd a pd.DataFrame({ A: [1, 2, None, 4, 5], …