Apache Pulsar 8 月月报：大放异彩，里程碑一个接一个

本月看点速览

• 产品动态
• 新增 PIP
• 新增功能
• Bug 修复
• 社区动态
• 海内外社区动态
• 技术干货

关于 Apache Pulsar

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

导语

各位小伙伴们，Pulsar 社区月报如约而至！

本月 Pulsar 社区内发生了不少「大事」。经历 8 个月后，项目贡献者已从 200 人到达 300+，日新月异。同时产品部分，Pulsar 也从 2.6.0 更新到了 2.6.1，修复了以前的 bug，合并了来自社区的 102 个 commit，感谢如下各位大佬本月对 Pulsar 项目的支持，让 Apache Pulsar 继续发光发热！（排名不分前后，看看你有没有上榜 🏆🏆）：

@jianyun802三、@31515797三、@ebyhr、@BewareMyPower、@hangc027六、@wolfstudy、@sijie、@srkukarni、@jiazhai、@merlimat、@sijia-w、@Jennifer88huang、@Mefl、@codelipenghui、@geetha-rangaswamaiah、@zhanghaou、@RobertIndie、@BewareMyPower、@rudy2steiner、@gaoran十、@massakam、@zymap、@aahmed-se、@MarvinCai、@Bklyn

产品动态

Go Client 0.2.0 版本已发布，更多功能介绍能够参考下方连接：
https://github.com/apache/pul... 。

🧰 新增 PIP

PIP 69: Schema design for Go client

在基于 Pulsar 构建的一系列应用程序中，类型安全是一个很重要的特性。当前 Apache Pulsar 已经支持了 Schema Registry 的功能。而且 Java、CPP 和 Python clients 已经支持了 Schema 相关的功能。为了进一步完善 Go client 的功能，咱们也须要在 Go client 中支持 Schema Registry。

更多详情查看：
https://github.com/apache/pul...

🧰 新增功能

Broker：支持在 Topic 级别设置 MaxUnackedMessagesOnConsumer
https://github.com/apache/pul...

Broker：支持在 Topic 级别设置 persistence 策略
https://github.com/apache/pul...

Broker：支持在 Topic 级别进行重复数据删除
https://github.com/apache/pul...

Java Client：支持批量消息签收
https://github.com/apache/pul...

Python CLient：在 Python 客户端添加 oauth2 封装
https://github.com/apache/pul...

Java Client：支持在生产者和发送者设置 autoPartitionsUpdateInterval
https://github.com/apache/pul...

Transaction：改进对消费事务消息的支持
https://github.com/apache/pul...

Transaction：支持将生产的事务型消息发送到 Pulsar broker 并执行提交命令
https://github.com/apache/pul...

Topic Policy：支持在 Topic 级别设置存留配额
https://github.com/apache/pul...

Topic policy：支持在 Topic 级别设置 MaxUnackMessagesPerSubscription
https://github.com/apache/pul...

Topic policy：支持设置 Topic 级别的消息延迟策略
https://github.com/apache/pul...

Build：将 Presto 升级到 332 版本
https://github.com/apache/pul...

Pulsar-IO hdfs2：增长从当前时间建立子目录的配置，方便批量处理 HDFS 文件
https://github.com/apache/pul...

Broker：增长支持对 ZooKeeper 缓存执行器线程池大小可配置
https://github.com/apache/pul...

Broker：增长支持对 orderedExecutor 线程数可配置
https://github.com/apache/pul...

🔧 Bug 修复

Java Client：避免重复订阅同一主题
https://github.com/apache/pul...

Broker：当经过 message ID 查询消息时，若是当前 broker 不负责此 topic，重定向至 owner broker
https://github.com/apache/pul...

Java Client：修复 PersistentAcknowledgmentsGroupingTracker 中的 pendingBatchIndexAcks，bitSet 和 batchSize
https://github.com/apache/pul...

CPP Client：修复因 seeking 或关闭消费者而致使的竞态条件
https://github.com/apache/pul...

Security：修复 Pulsar 组件安全漏洞
https://github.com/apache/pul...

Security：运用 ‘allowTopicOperationAsync’ 来检查原始角色是不是超级用户
https://github.com/apache/pul...

Security：在源/接收器/功能操做之间区分受权
https://github.com/apache/pul...

CPP client：修复 Oauth2 认证中的 issuer_url 解析失败问题
https://github.com/apache/pul...

CPP client：修复建立 reader 时的引用泄漏
https://github.com/apache/pul...

Admin Client：确保当从一个不存在的 namespace 删除一个分区主题时返回 404 报错
https://github.com/apache/pul...

Broker：修复建立 ledger 超时时 producer 卡顿的问题
https://github.com/apache/pul...

社区动态：多个里程碑

📣 Pulsar 贡献人数超 300
8 月 21 日，Apache Pulsar 的 GitHub 项目 contributor 数量正式超过 300 位。距离 200 人仅过去 8 个月，感谢各位的积极参与和项目共享。Pulsar 也因大家更精彩！

更多详情可查看➡️ Apache 软件基金会顶级项目 Pulsar 达成新里程碑：全球贡献者超 300 位!

📣 Pulsar 云服务功能上线
Apache 顶级项目 Pulsar 背后的开源流数据公司 StreamNative 宣布，推出基于 Apache Pulsar 的云端服务产品——StreamNative Cloud。该产品的发布，让 Pulsar®-as-a-Service（PaaS）成为现实 ，加速 Pulsar 推广与落地，助力企业推动“流优先”策略。

更多详情可查看➡️ 开源流数据公司 StreamNative 推出 Pulsar 云服务，推动企业“流优先”进程

📣 2.6.1 版本上线
8 月 21 日，Pulsar 2.6.1 版本正式上线。此版本修复了 2.6.0 版本中的诸多问题，改进了一些功能，新增了对 OAuth2 的支持，覆盖了 Broker、Pulsar SQL、 Pulsar Functions、Go Function、Java Client 和 Cpp Client，进一步丰富了 Pulsar 做为云原生流数据平台的能力。

更多详情可查看➡️ Apache Pulsar 2.6.1 版本正式发布：2.6.0 功能加强版，新增 OAuth2 支持

📣 Pulsar 联合 TiDB 推出大数据场景数据应用分析解决方案
Pulsar 与 TiDB 推出联合解决方案，提供实时、高吞吐、稳定的数据输出，知足用户在大数据场景中对各种数据的应用与分析需求，普遍适用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等场景。目前该解决方案已经在伴鱼少儿英语（互联网在线英语教育品牌）、知乎（中文互联网综合性内容平台）、石基信息（酒店业信息系统解决方案服务商）等多家行业顶尖公司落地。

更多详情可查看➡️ 强强联手！Pulsar 联合 TiDB 推出大数据场景数据应用分析解决方案

TGIP 系列直播

💙 TGIP-CN

• 019: Pulsar 如何应用到数据查询中
• 020: Pulsar namespace 策略的简单小介绍
• 021: 来咯！Pulsar 2.6.1 版本发布前瞻
• 022: 订阅状态的复制？跨机房同步下如何应用

TGIP-CN 系列全部回放视频可参考 b 站连接：
https://www.bilibili.com/vide...

💜 TGIP
018: From Single-AZ to Multi-AZ and Geo-replication
https://www.youtube.com/watch...

📣 网络研讨会合集

➡️ 8月25日: StreamNative 在线研讨会

题目：Managing Real-Time Data Teams
主讲人：Jesse Anderson，Big Data Institute 大数据专家

视频回顾参考下方连接：
https://www.youtube.com/watch...

➡️ 9月9日：Israeli Java Community (Java.IL) meetup

题目：Apache Pulsar——Under the Hood for Java Developers
主讲人：Addison Higham，StreamNative 高级软件工程师，拥有丰富的 Apache 项目经验

活动报名连接参考：http://meetup.com/JavaIL/even...

技术干货

• Apache Pulsar 的访问模式与分层存储
• Apache Pulsar 在 BIGO 的性能调优实战（上）
• Global and local Apache ZooKeeper in Apache Pulsar - part 2 - Bartosz Konieczny

以上就是 8 月份的脉动之旅。Apache Pulsar 正在快速成长，感谢来自你们的支持！

---

Apache Pulsar 社区鼓励你们积极参与开源社区，不管是文档、代码、翻译，仍是技术博客，都欢迎你们积极参与，早日成为 Pulsar contributor，一块儿加油鸭。

若是你对 Pulsar Contribute 的流程不太熟练，也能够参考咱们这篇小教程，让你熟悉如何经过 GitHub 对 Pulsar 进行贡献：新手向｜非技术人员如何参与 Pulsar 项目进行贡献

参与贡献项目可选：

• Apache Pulsar 项目: https://github.com/apache/pulsar
• Pulsar 技术文档翻译: https://github.com/apache/pul...