乐趣区

关于pulsar:Apache-Pulsar-9月月报Pulsar-Summit-亚洲站正式启动

本月看点速览

  • 产品动静

    • 新增性能
    • Bug 修复
  • 社区动静

    • 海内外社区动静
    • 技术干货

对于 Apache Pulsar

Apache Pulsar 是 Apache 软件基金会顶级我的项目,是下一代云原生分布式音讯流平台,集音讯、存储、轻量化函数式计算为一体,采纳计算与存储拆散架构设计,反对多租户、长久化存储、多机房跨区域数据复制,具备强一致性、高吞吐、低延时及高可扩展性等。

导语

各位小伙伴们,Pulsar 社区月报如约而至!

本月 Pulsar 社区内也进行了很多产品细节欠缺和更新。本月咱们合并了来自社区的 126 个 commit,同时 transaction 和 topic policy 方面也在逐步欠缺,置信不久就会和大家见面。 感激以下各位大佬本月对 Pulsar 我的项目的反对,让 Apache Pulsar 持续发光发热!(排名不分先后,看看你有没有上榜 ????????):

@congbobo184 @merlimat @hrsakai @srkukarni @zymap @gaoran10 @aahmed-se @315157973 @mkozioro @zhanghaou @BewareMyPower @wolfstudy @hangc0276 @jerrypeng @aloyszhang @codelipenghui @Technoboy- @equanz、@kellyfj、@jianyun8023、@MarvinCai、@cimura、@tuteng、@Jennifer88huang、@RobertIndie、@massakam、@Bklyn、@jiazhai、@lukestephenson-zendesk、@sijia-w、@yuku、2aloyszhang、@Huanli-Meng、@david-streamlio

产品动静

通过一直地致力,社区在本月胜利公布 Pulsar Flink Connector 2.5.0 版本。Pulsar Flink Connector 集成了 Apache Pulsar 和 Apache Flink(数据处理引擎),容许 Apache Flink 向 Apache Pulsar 读写数据。

更多详情可参考➡️ Pulsar Flink Connector 2.5.0 正式公布。

9 月 28 日,StreamNative 发表开源了 “MoP”(MQTT on Pulsar)。MoP 将 MQTT 协定解决插件引入 Pulsar broker。这样一来,Apache Pulsar 就能够反对原生 MQTT 协定。与 KoP 类似,MoP 是一种可插拔的协定解决插件。

更多详情可参考➡️ StreamNative 发表开源 MoP!。

Pulsar Manager 也在明天公布了 0.2.0 版本,具体版本更新细节能够参考官网:http://pulsar.apache.org/en/p…。

???? 新增性能

  • Transaction: 处理事务中的音讯确认
    https://github.com/apache/pul…
  • Transaction: 反对对分区事务的异样终止
    https://github.com/apache/pul…
  • Transaction: 优化生产事务型音讯的逻辑
    https://github.com/apache/pul…
  • Topic Policy: 反对在 Topic 级别设置、获取和移除 inactiveTopicPolicies
    https://github.com/apache/pul…
  • Topic Policy: 反对在 Topic 级别设置卸载策略
    https://github.com/apache/pul…
  • Topic Policy: 反对在 Topic 级别设置、获取和移除 maxProducers
    https://github.com/apache/pul…
  • Topic Policy: 反对在 Topic 级别设置、获取和移除压缩阈值
    https://github.com/apache/pul…
  • Broker: Pulsar Functions 的消费者 / 生产者属性反对主机名
    https://github.com/apache/pul…
  • Broker: Pulsar primitive schema 反对 Java 8 日起和工夫类型
    https://github.com/apache/pul…
  • Broker: BatchPushSource 反对异步告诉谬误
    https://github.com/apache/pul…
  • Broker: 反对在 Topic 级别上设置音讯发送速率的流控
    https://github.com/apache/pul…
  • Bookie: 增加 bookkeeperClientMinNumRacksPerWriteQuorum 和 kkeeperClientEnforceMinNumRacksPerWriteQuorum 配置选项
    https://github.com/apache/pul…
  • Topic Policy: 反对在 topic 级别设置、获取、删除 maxConsumers
    https://github.com/apache/pul…
  • Transaction: 更新 subscription 的确认停止过程
    https://github.com/apache/pul…
  • Topic Policy: 修复 dispatchRate 的笼罩程序
    https://github.com/apache/pul…
  • C++ Client: C ++ 客户端反对基于键的批处理
    https://github.com/apache/pul…
  • Pulsar Perf: 反对在 Key_Shared 订阅模式下,为 consumer 设置音讯主键
    https://github.com/apache/pul…
  • OAuth2: 从 well-known configuration 门路下获取 OAuth2 token 端点
    https://github.com/apache/pul…
  • Functions: Pulsar Functions 反对指定订阅地位
    https://github.com/apache/pul…
  • Topic Policy: 反对在 topic 级别设置、获取、删除每个订阅的 maxConsumers
    https://github.com/apache/pul…
  • Transaction:反对批处理音讯的 pending-ack 状态
    https://github.com/apache/pul…
  • Pulsar Broker:反对配置 HTTP 申请的根本速率限度
    https://github.com/apache/pul…
  • Bookie:更新 BookKeeper main 办法类
    https://github.com/apache/pul…
  • Bouncy Castle:降级 Bouncy Castle 至最新版本
    https://github.com/apache/pul…

???? Bug 修复

  • Broker: 修复 broker 端确认音讯时呈现的 NPE(空指针异样)问题
    https://github.com/apache/pul…
  • Broker: 在 Key_Shared 订阅模式下,当消费者无奈生产音讯造成长期跳过音讯时,暂停公布音讯
    https://github.com/apache/pul…
  • Metrics: 修复提供错误信息的 Pulsar metrics
    https://github.com/apache/pul…
  • CPP Client: 确保 BatchAcknowledgementTracker 和 UnAckedMessageTrackerEnabled 的 clear() 办法线程平安
    https://github.com/apache/pul…
  • Broker: 通过 Ledger ID 划分音讯范畴,并将其存储在 individualDeletedMessages 中
    https://github.com/apache/pul…
  • Broker: 修复增加消费者时产生的死锁问题
    https://github.com/apache/pul…
  • CPP Client: 异样解决中,抛出 std::exception 类来代替 char*
    https://github.com/apache/pul…
  • Functions: 优化批处理源的 close() 过程出现异常时的解决形式谬误
    https://github.com/apache/pul…
  • Functions: 改良批处理外部 topic 革除的操作
    https://github.com/apache/pul…
  • Security: 将 snakeyaml 降级到版本 1.26
    https://github.com/apache/pul…
  • Broker: 当查看 broker 端公布缓存时,防止多次重复计算一个 ServerCnx 的公布缓存
    https://github.com/apache/pul…
  • OAuth2: 修复应用 OAuth2 认证插件启动代理服务时呈现的 Null Exception 异常情况
    https://github.com/apache/pul…
  • Broker: 修复在 Key_Shared 订阅模式下将音讯分发给消费者时呈现的 IndexOutOfBoundsException 异常情况
    https://github.com/apache/pul…
  • Security:若客户端身份验证失败,防止从新连贯到服务器
    https://github.com/apache/pul…
  • Transaction:修复 transaction 音讯确认问题
    https://github.com/apache/pul…
  • Pulsar Client:在 PulsarClientTool 中,增加 tlsEnableHostnameVerification 可配置
    https://github.com/apache/pul…

社区动静

???? TGIP 系列直播

???? TGIP-CN

  • 024: AMQP on Pulsar 的设计与利用一览
  • 025: Apache Pulsar 问答专场(可间接参考下方视频链接进行回顾)

TGIP-CN 系列所有回放视频可参考:https://www.bilibili.com/vide…。

???? 网络直播:Israeli Java Community

9 月 9 日,工程师 Addison Higham 在 Israeli Java Community (Java.IL) 流动中分享了「Apache Pulsar: Under the Hood for Java Developers」的相干内容。

???? PPT 参考:https://www.slideshare.net/st…

???? 回放视频参考:https://www.youtube.com/watch…

???? 社区重大流动

???? Apache DolphinScheduler x Pulsar 在线 Meetup

9 月 5 日,Apache Pulsar 联结 Apache DolphinScheduler 举办了线上 meetup,此次流动汇集了 200+ 小伙伴,直播观看人次冲破 1000+。

更多内容可查看➡️ 流动回顾|Apache DolphinScheduler x Pulsar 在线 Meetup

???? Pulsar Summit Asia 2020 正式启动,演讲征集中

往年 6 月份咱们胜利举办了寰球参加的 Pulsar Summit Virtual Conference。为了更好地汇集亚洲地区 Pulsar 开发者和贡献者,Pulsar Summit Aisa 2020 将于 11 月 28-29 日召开!思考到疫情,此次峰会将全面线上举办,目前演讲议题仍在凋谢征集中,欢送报名!

更多内容可查看➡️ [Pulsar Summit Asia 2020 正式启动,演讲议题征集中!]https://segmentfault.com/a/11…

???? 年度开源盛会 ApacheCon 降临,Apache Pulsar 专场大咖齐聚

2020 年 ApacheCon 大会全程线上举办,从 9 月 29 日到 10 月 1 日,会议共继续 3 天。Apache Pulsar 作为 Apache 软件基金会顶级我的项目,在本次大会开设了 Apache Pulsar 专场论坛。

Pulsar 专场详情可参考:https://apachecon.com/acah202…

更多内容可查看➡️ 年度开源盛会 ApacheCon 降临,Apache Pulsar 专场大咖齐聚

???? 2020 中国开源年会 COSCon’20 再启程,Apache Pulsar 社区成为本大会社区合作伙伴

2020 中国开源年会 COSCon’20 将于往年 10 月 24-25 日举办,将在线上进行丰盛的直播流动,并在上海、北京、深圳和成都设立分会场,广邀当地的小伙伴们一起退出到这场开源盛事中来。同时会有多位导师进行各种各样的主题演讲,为大家带来不一样的开源之旅。

Apache Pulsar 社区荣幸成为此次开源年会的社区合作伙伴。

???? 开源流数据公司 StreamNative 正式退出 CNCF

近日,开源流数据公司 StreamNative 发表正式退出云原生计算基金会 CNCF(全称:Cloud Native Computing Foundation),成为 CNCF 共建云原生社区的重要合作伙伴。

更多内容可查看➡️ 开源流数据公司 StreamNative 正式退出 CNCF,踊跃推动云原生策略倒退

同时对 StreamNative 公司联结创始人兼 CTO 翟佳进行了系列采访,相干采访可查看➡️ 专访 PMC,开源我的项目 Apache Pulsar 如何挑战 Kafka?

技术干货

  • 译文|Apache Pulsar 的分层存储
  • 译文|如何将 Pulsar 用作音讯队列
  • The role of Apache BookKeeper in Apache Pulsar – part 1 – Bartosz Konieczny
  • 10 Reasons for Choosing Apache Pulsar over Apache Kafka
  • StreamNative Cloud – Getting Started

以上就是 9 月份的脉动之旅。Apache Pulsar 正在疾速成长,感激来自大家的反对!

Apache Pulsar 社区激励大家积极参与开源社区,无论是文档、代码、翻译,还是技术博客,都欢送大家积极参与,早日成为 Pulsar contributor,一起加油鸭。

如果你对 Pulsar Contribute 的流程不太纯熟,也能够参考咱们这篇小教程,让你相熟如何通过 GitHub 对 Pulsar 进行奉献:老手向|非技术人员如何参加 Pulsar 我的项目进行奉献

参加奉献我的项目可选:

  • Apache Pulsar 我的项目:https://github.com/apache/pulsar
  • Pulsar 技术文档翻译:https://github.com/apache/pul…
退出移动版