乐趣区

关于pulsar:Apache-Pulsar-12-月月报Pulsar-270-发布

jiezi

对于 Apache Pulsar

Apache Pulsar 是 Apache 软件基金会顶级我的项目，是下一代云原生分布式音讯流平台，集音讯、存储、轻量化函数式计算为一体，采纳计算与存储拆散架构设计，反对多租户、长久化存储、多机房跨区域数据复制，具备强一致性、高吞吐、低延时及高可扩展性等流数据存储个性。
GitHub 地址：http://github.com/apache/pulsar/
本月报由 StreamNative 团队整顿。

导语

各位小伙伴们，2020 年 12 月 Pulsar 社区月报来啦！首先给大家一个早退的 2021 新年祝愿！

本月 Pulsar 社区欠缺和更新很多产品细节，遍布方方面面。感激以下各位社区成员本月对 Pulsar 我的项目的反对，让 Apache Pulsar 持续发光发热！（排名不分先后，看看你有没有上榜 ????????）：

@jeames00、@congbobo184、@Renkai、@reswqa、@lhotari、@codelipenghui、@jerrypeng、@eolivelli、@wolfstudy、@nodece、@erobot、@315157973、@gaoran10、@zymap、@eolivelli、@reswqa、@RobertIndie、@Gjiangtao、@erobot、@mkozioro、@massakam、@k2la、@Renkai、@Jennifer88huang、@tuteng、@zsh0139、@Huanli-Meng、@aahmed-se、@sijie、@sijia-w、@rathipry、@hangc0276、@BewareMyPower、@jianyun8023、@merlimat、@aloyszhang、@MarvinCai、@dockerzhang、@rdhabalia、@flowchartsman、@aloyszhang、@jerrypeng、@massakam、@sijie、@jiazhai、@cimura、@zzzming、@codelipenghui、@rdhabalia、@zymap、@saosir、@massakam、@dockerzhang、@Shoothzj、@eolivelli、@gaoran10、@milos-matijasevic、@k2la、@deonvdv、@wangjialing218、@astifter、@yufan022

产品动静

Function

Function: 在 Go Function builder 中反对 key-based 批处理。

https://github.com/apache/pul…

Function：为示意 function 状态的 openTable() 调用增加超时。

https://github.com/apache/pul…

Function: 提供 Function worker 服务的接口。

https://github.com/apache/pul…

Function：在 Function 中容许批改状态不阻塞 function 运行。

https://github.com/apache/pul…

Function: 使源 topic 的 schema 信息可用于上游 sinks。

https://github.com/apache/pul…

Function: 在 Pulsar Functions 中增加 --retain-key-ordering 标识。

https://github.com/apache/pul…

Function: 反对通过配置 URL 获取 Go 和 Python function。

https://github.com/apache/pul…

Function Worker: 拆分 Function Worker 和客户端的身份验证逻辑。

https://github.com/apache/pul…

Package management

Package management: 将包治理服务增加到 Pulsar 启动过程中。

https://github.com/apache/pul…

Package management: 包治理服务反对 BookKeeper 存储。

https://github.com/apache/pul…

Tiered storage

Tiered storage: 初始化 offloader 时，只初始化一次即可。

https://github.com/apache/pul…

Test

Test: pulsar-perf 反对多 consumer 订阅。

https://github.com/apache/pul…

Java Client

Java Client: Java 客户端反对设置 reader 的订阅名。

https://github.com/apache/pul…

Java Client: 实现 producer 内存限度。

https://github.com/apache/pul…

Java Client: 反对 producer 的 WaitForExclusive 创立模式。

https://github.com/apache/pul…

Schema

Schema: 为 SchemaInfoBuilder 中的属性增加默认值。

https://github.com/apache/pul…

KoP

KoP: 反对应用指定统计数据更新统计数据。

https://github.com/apache/pul…

Websocket

Websocket: 反对 WebSocket producer 的 deliveryAt 和 deliverAfter 属性。

https://github.com/apache/pul…

WebSocket：依据 PulsarClientException 的类型返回状态代码。

https://github.com/apache/pul…

C++

C++ Client: 为 reader 增加 consumer 配置，用于解密加密的音讯。

https://github.com/apache/pul…

C++ Client: C++ 客户端反对为设置 reader 的外部订阅名称设置增加 setter。

https://github.com/apache/pul…

C++: 优化批音讯缓存调配。

https://github.com/apache/pul…

C++：更正订阅 API 的参数名称。

https://github.com/apache/pul…

Broker

Broker: 反对在 topic 级别配置每个 topic 的最大订阅数。

https://github.com/apache/pul…

Broker: 导出 messageTTL 的 Prometheus 指标。

https://github.com/apache/pul…

Broker: 实现软件包治理的管理者操作。

https://github.com/apache/pul…

Broker: 引入轻量级 broker 元数据。

https://github.com/apache/pul…

Broker: 增加用于包治理服务的 REST API。

https://github.com/apache/pul…

Broker: 将软件包治理服务增加到 Pulsar 启动过程过程中。

https://github.com/apache/pul…

Broker: 将 getWebServiceUrl 办法更改为异步。

https://github.com/apache/pul…

Broker: 反对客户端软件包治理命令。

https://github.com/apache/pul…

Broker：引入 Pulsar 的间断偏移量。

https://github.com/apache/pul…

Broker：为 KoP 增加 updateRates 办法，采集公布速率。

https://github.com/apache/pul…

Broker：反对配置 Netty Acceptor 线程池大小。

https://github.com/apache/pul…

Broker：反对查看 broker entry 元数据。

https://github.com/apache/pul…

Broker: 反对限度每个 namespace 的最大 topic 数量。

https://github.com/apache/pul…

Broker: 裸露不间断的已删除音讯的统计数据。

https://github.com/apache/pul…

Broker: 增加 beforeSendMessage 办法，在将 entry 发送给 consumer 之前拦挡 entry。

https://github.com/apache/pul…

Broker: 反对在 namespace 级别配置每个 topic 的最大订阅数量。

https://github.com/apache/pul…

Broker：改良 broker 不信赖客户端证书时的错误处理。

https://github.com/apache/pul…

Broker：使 namespace 隔离策略更新及时失效。

https://github.com/apache/pul…

Broker：为 SubscriptionBusyException 增加 if 分支。

https://github.com/apache/pul…

Broker：删除反复的 broker Prometheus 指标类型。

https://github.com/apache/pul…

Broker：增加原始 Prometheus 指标提供者。

https://github.com/apache/pul…

Broker：反对 Pulsar-admin 主动刷新证书。

https://github.com/apache/pul…

其余

引入 Pulsar 的的间断偏移量。

https://github.com/apache/pul…

Perf：pulsar-perf 反对从 conf 文件加载 WebSocket 服务 URL。

https://github.com/apache/pul…

SQL：为 SQL 测试增加重试。

https://github.com/apache/pul…

Bug 修复

Broker

Broker: 应用新的线程删除非长久化订阅，以防止在删除不沉闷订阅时呈现死锁。

https://github.com/apache/pul…

Broker: 反对在删除给定 namespace 时删除其所有 topic。

https://github.com/apache/pul…

Broker: 删除从不同线程中删除 topic 的非长久永恒订阅，从而防止在删除非流动订阅时呈现死锁。

https://github.com/apache/pul…

Broker: 修复了因有效的日志记录配置导致的性能问题。

https://github.com/apache/pul…

Broker: 查看音讯到期时复制订阅列表，防止死锁。

https://github.com/apache/pul…

Broker: 修复因音讯保留而导致空 topic 无奈获取 lastMessageId 的问题。

https://github.com/apache/pul…

Broker: 修复 PersistentStickyKeyDispatcherMultipleConsumers 中的 NPE。

https://github.com/apache/pul…

Broker: 清理无奈从缓存中卸载的 topic。

https://github.com/apache/pul…

Broker: 更新 Maven 工件版本。

https://github.com/apache/pul…

Broker: 解决了元数据导致的兼容性的问题。

https://github.com/apache/pul…

Broker: 修复了在没有散发速率限度的状况下卸载 topic 后，订阅的散发速率无奈工作的问题。

https://github.com/apache/pul…

Broker: 确保动静更新 rack 信息。

https://github.com/apache/pul…

Broker: 修复 Pulsar broker 中我的项目的格局谬误。

https://github.com/apache/pul…

Broker：修复 DelayedDelivery 在 broker 层级有一个默认值的问题。

https://github.com/apache/pul…

Function

Function: 修复增加到用户配置中的单引号的问题。

https://github.com/apache/pul…

Function: 修复了 Go Function 抛弃音讯触发的 panic。

https://github.com/apache/pul…

C++ Client: 修复 BlockingQueue 中的竞态条件。

https://github.com/apache/pul…

Schema: GenericJsonReader 将空值转换为字符串“null”。

https://github.com/apache/pul…

Client

Java Client: 修复当 Pulsar 客户端收到来自已敞开 producer 公布的音讯确认时呈现的 NPE 问题。

https://github.com/apache/pul…

Java Client: 在发送 TimeoutException 进行故障排除时增加更多信息。

https://github.com/apache/pul…

Java Shade Client: 增加加密集成测试。

https://github.com/apache/pul…

Pulsar Client: 修复带有加密字段 (*) 的 authParams 参数在日志中显示的问题。

https://github.com/apache/pul…

Client：修复不可用的 Hash 范畴条件。

https://github.com/apache/pul…

Admin

Admin: 修复 AdminApiTest2.testMaxSubPerTopicApi 的 Flaky test。

https://github.com/apache/pul…

Pulsar-managed-ledger-admin：修复删除多个 ledger。

https://github.com/apache/pul…

Pulsar CI

Pulsar CI: 通过在 MAVEN_OPTS 环境变量中传递 -Dhttp.keepAlive = false -Dmaven.wagon.http.pool = false 来禁用 Maven 的 HTTP 连接池。

https://github.com/apache/pul…

其余

Pulsar IO: 修复 pulsar-io.yaml 文件名和 sourceConfigClass 类。

https://github.com/apache/pul…

Schema: 修复自定义 Avro schema 不适用于 consumer 的问题。

https://github.com/apache/pul…

Pulsar Build: 应用绝对路径查找许可证和 checkstyle 插件配置。

https://github.com/apache/pul…

Pulsar Package: 修复包无奈上传的问题。

https://github.com/apache/pul…

Common：修复查看压缩音讯时引发异样的问题（Airlift 不反对只读缓冲区）。

https://github.com/apache/pul…

Transaction：修复 transaction 音讯程序谬误和去重谬误。

https://github.com/apache/pul…

Proxy：从代理服务器向客户端返回正确的 Authz 和 Auth 谬误。

https://github.com/apache/pul…

社区动静

  • Pulsar User Survey 2020

点击“浏览原文”或扫码下方二维码，参加 Pulsar 2020 用户考察，填写问卷有机会取得新版 Pulsar 周边哦！

  • TGIP-CN 028: Apache Pulsar 延时队列的设计与实现

    • Pulsar Summit Asia 2020 视频回顾
    • ApacheCon 2020 – Pulsar/ BookKeeper 专场

技术干货

  • Impact of Apache Pulsar 2.7 release on the development of Infinitic
  • Cloud-Native Apache Pulsar 2.7 Supports Transactions and Azure Blob Storage Offloader
  • Work-Bench Snapshot: Augmenting Streaming and Batch Processing Workflows
  • How Apache Pulsar is Helping Iterable Scale its Customer Engagement Platform
  • Using Apache Pulsar With Kotlin — Gilles Barbier
  • Pulsar 2.7.0 新个性
  • Pulsar Flink Connector 2.7.0 新个性

以上就是 2020 年 12 月份的脉动之旅。Apache Pulsar 正在疾速成长，感激来自大家的反对！

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

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

退出移动版