Pulsar 社区周报 | No.20250313 ｜广州 Meetup 来啦

Pulsar 2025 年度第一场 Meetup 来啦！

广州 Meetup｜Pulsar AI+ 议题征集 | PulsarMeetup 广州 2025 大会正式启动！

我们非常荣幸地宣布，2025 年3月29日，在广州，由谙流科技（AscentStream）和腾讯云中间件联合主办的 PulsarMeetup 广州 2025 大会即将开幕！

Apache Pulsar 社区和合作伙伴诚邀 Pulsar 和各大社区的小伙伴、广大技术爱好者、架构师和企业代表参与。

• 活动主题 ：PulsarMeetup 广州2025
• 主办单位 ：谙流科技、腾讯云中间件
• 活动时间 ：2025年 3月29日 14:00~18:00，周六下午
• 活动地点 ：广州市海珠区新港中路397 TIT创意园 B4 栋 402 会议室（3号线/8号线-客村A出口）
• 活动形式 ：线下为主，线上同步直播，

大会邀请了包括腾讯、华为、BIGO 和谙流科技等诸多 Pulsar 专家，给大家分享最新的 Pulsar 场景案例、 技术探究、 运维实战和生态演讲，详见议程。干货多多，不容错过。

“

本次 Meetup 受场地限制，人数将控制在 60 人，邀请大家尽早报名。另保留好报名成功短信或者邀请函，将凭此入场。

”

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

“

@shibd,@poorbarcode,@gaoran10,@gunli,@lhotari,@kontotto,@horizonzy,@jiangpengcheng,@StevenLuMT,@RobertIndie,@dependabot[bot],@reugn,@crossoverJie,@Shawyeok

”

apache/pulsar

fix

•  [fix][broker]拼写更正：从 backlogQuotaDefaultLimitByte 更正为 backlogQuotaDefaultLimitBytes。  ^[1]  @StevenLuMT
•  [fix][broker]修复加载已终止主题后失败的消费问题  ^[2]  @poorbarcode
•  [fix][test]在IncrementPartitionsTest中更新分区主题的订阅断言  ^[3]  @kontotto
•  [fix]避免负的估计入口计数  ^[4]  @gaoran10
•  [fix] [common]修复 RawMessageImpl.getProperties() 失败的问题，当消息元数据包含相同的键但具有不同的值时。  ^[5]  @horizonzy

新特性

•  [improve][broker]优化 ThresholdShedder，改进边界检查和参数重用。  ^[6]  @crossoverJie
•  [improve][fn]实现 pip 401：支持为 Pulsar Functions 和 Sources 设置批处理配置  ^[7]  @jiangpengcheng
•  [improve][pip]PIP-396：使 WindowFunction 的 WindowContext 与 BaseContext 对齐  ^[8]  @jiangpengcheng

apache/bookkeeper

others

•  在 EntryLoggerAllocator 中为 Executor 设置 ThreadFactory  ^[9]  @Shawyeok

apache/pulsar-client-go

others

•  选择：删除多余的通道连接.incomingCmdCh  ^[10]  @gunli
•  改进消息解压错误  ^[11]  @RobertIndie
•  将 lz4 升级到 v4  ^[12]  @RobertIndie
•  修复在通过 ID 或时间进行查找后，reader.hasNext/Next 返回错误结果的问题。  ^[13]  @shibd
•  修复：潜在的数据竞争  ^[14]  @gunli
•  修复：潜在的数据/写入冲突  ^[15]  @gunli
•  chore(deps): 将 golang.org/x/net 从 0.23.0 升级到 0.33.0  ^[16]  @dependabot[bot]
•  依赖项：更新依赖版本  ^[17]  @reugn

apache/pulsar-client-node

others

•  修复使用 token 认证时的段错误。  ^[18]  @shibd

apache/pulsar-helm-chart

others

•  修复与 Broker 相关的 Grafana 仪表板，设置 honorLabels，移除不必要的 *_created 指标，并改善文档。  ^[19]  @lhotari
•  从 kube-prometheus-metrics 迁移到 victoria-metrics-k8s-stack  ^[20]  @lhotari
•  移除在 Kubernetes 1.25 中已被移除的 PodSecurityPolicy 支持，并将最低版本提升至 1.25。  ^[21]  @lhotari
•  当启用 podmonitors 时，请移除 Prometheus 抓取注释。  ^[22]  @lhotari
•  在 broker 中使用 bookkeeperMetadataServiceUri，并使 PulsarMetadataClientDriver 可配置。  ^[23]  @lhotari

参考资料