关于消息队列:脉冲星-3-月脉动-Pulsar-271-版本发布

41次阅读

共计 7349 个字符，预计需要花费 19 分钟才能阅读完成。

对于 Apache Pulsar

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

GitHub 地址：http://github.com/apache/pulsar/

导语

各位小伙伴们，2021 年 3 月 Pulsar 社区月报来啦！新年伊始，Pulsar 有哪些新年新气象呢？和咱们一起来看看吧。

感激以下各位社区成员本月对 Pulsar 我的项目的反对，让 Apache Pulsar 持续发光发热！（排名不分先后，看看你有没有上榜 🏆🏆）：

congbobo184、hangc0276、eolivelli、Huanli-Meng、lhotari、zymap、jerrypeng、david-streamlio、michaeljmarshall、Anonymitaet、kandersen82、klwilson227、freeznet、MarvinCai、RobertIndie、rdhabalia、fmiguelez、315157973、sijia-w、sakurafly123、tuteng、congbobo184、dlg99、timmyyuan、Jennifer88huang、yangl、aahmed-se、BewareMyPower、caladogan、gaoran10、csthomas1、wuzhanpeng、linlinnn、mauza、xiaotongwang1、limingnihao、murong00、merlimat、codelipenghui、fanjeff、patricklucas、golden-yang、mlyahmed、limingnihao、BewareMyPower、HugeSkull、hnail、massakam、wolfstudy、bithavoc

重要停顿

Broker

Broker：反对获取利用的 BlacklogQuota。

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

Broker：反对获取利用的 SubscriptionDispatchRate。

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

Broker：将待处理的读订阅指标增加到 stats-internal。

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

Broker：为 PulsarService#getAdminClient 增加 NPE 查看。

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

Broker：避免应用有效的 broker 或 proxy configuration 设置受权。

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

Broker：将 getWorkerService 办法更改为抛出 UnsupportedOperationException。

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

Broker：如果响应曾经提交，则不增加 broker-address 标头。

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

Broker：验证 /offload 申请的参数。

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

Broker：反对获取已利用的 PersistencePolicies。

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

Broker：反对获取已利用的 clusterSubscribeRate。

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

Broker：反对获取已利用 dispatchRate。

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

Broker：反对获取压缩阀值。

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

Build

Build：从 Pulsar docker 镜像中删除 .deb 包。

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

Build：将 pulsar-io-kafka-connect-adaptor 拆分为 JAR 和 NAR 模块。

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

Build：启用具体的 Java 编译器告警。

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

Build：设置我的项目版本时，更新 terraform 文件中的 Pulsar 版本。

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

C++

C++ client：从 C++ 库中删除 gtest 文件。

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

C++ Client：实现 C++ producer 中内存限度。

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

CI

CI：在重试或继续执行下一测试之前，革除测试失败的状态。

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

CI：在 CI 测试中增加 apache-rat check。

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

CI：将集成测试命令重构为 run_integration_group.sh 脚本。

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

CI：应用 DiagnosticCommand JMX MBean 实现线程转储。

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

CI：通过仅涵盖选定的 connectors 来减小集成测试镜像的大小。

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

Client

Go client：将 JWT-Go 版本更新为 v4。

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

Pulsar Client：反对输入 GenericRecord 内容。

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

WebSocket Client：反对浏览器客户端进行 token 身份验证。

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

Pulsar-client：Pulsar REST API、pulsar-admin 和 pulsar-client CLI 工具减少获取 Pulsar 版本的命令。

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

Client: 反对为 MultiTopicsReaderImpl 设置多 topic。

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

Client：应用不同的 listener-threads 解决不同分区 topic 的音讯。

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

Transaction

Transactions：对 End transaction 操作进行重试。

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

Transactions：反对查看 transaction 状态。

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

Transactions：实现 transaction 缓冲区快照。

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

Transactions：革除 transaction buffer 中勾销的 transaction。

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

其余

Common：优化 ConcurrentOpenHashMap，缩短读锁死的持续时间。

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

WebSocket：在 WebSocket 服务器中反对 pong 逻辑。

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

WebSocket：容许 WebSocket proxy 在不解密的状况下将消息传递给客户端生产。

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

Authentication: 在 AuthenticationTls 中反对序列化 stream-provider 字段。

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

Kafka：在 KafkaBytesSource 中反对 KeyValue。

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

Pulsar SQL：反对查问大写的 topic。

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

Utils：转储 pulsar-perf 的 JVM 信息。

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

Deployment：更新 Ansible 的部署配置中 Pulsar 的版本至 2.7.0。

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

Pulsar-admin：增加命令以获取 leader broker 的 service URL。

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

Pulsar-Discovery：在 discoveryservice 中将 ZooKeeper 替换为 MetadataStore。

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

Schema：将 Apache Avro 降级到 1.10.2 版本。

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

Metrics：增加 broker 连贯指标。

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

Pulsar IO：Kafka source connector 反对治理 Avro 编码的音讯。

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

Test:：将 TestNG 组增加到 Pulsar broker。

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

Bug 修复

Broker

Broker：修复 2.7 分支上 Topic 为空时 hasMessageAvailable() 导致的谬误。

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

Broker：修复 2.7 分支上获取 topic 利用策略时未查看 topic 所有权的问题。

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

Broker：修复主分支上获取 topic 利用策略时未查看 topic 所有权的问题。

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

Broker：修复 PersistentReplicator 中的 NPE 和线程平安问题。

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

Broker：修复如果达到最大订阅限度，consumer 无奈应用较旧的订阅来生产音讯的问题。

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

Broker：即便 Web 服务无奈敞开，也能够持续失常敞开 broker 服务。

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

Broker：记录在 ExecutorProvider 中超时后，在敞开时未终止的线程栈轨迹的日志。

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

Broker：反对在 broker.conf 文件中禁用 tenants/namespaces 强制删除。

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

Broker：容许 broker 发现并解锁卡住的订阅。

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

Broker：修复 zkBookieRackAffinityMapping 破绽，反对 BookKeeper 的 dnsResolver。

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

Broker：修复在 key_shared 订阅模式下无奈生产非长久音讯的问题。

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

Broker：修复更新 lastLedgerCreationInitiationTimestamp 时呈现的工夫单位谬误的问题。

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

C++

C++：修复已暂停的零队列 consumer 仍预取音讯的问题。

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

C++：反对简略地配置调试级别的日志。

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

C++：修复从接管到的音讯 ID 中获取 topic 名称时的宰割谬误。

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

Client

Java client：修复 ClientCnx 中的 NPE。

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

Go client：修复 lookup service 中的 socket 透露的问题。

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

Client：确保能够敞开单 topic 的 consumer。

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

Client：修复从字节数组反序列化时未设置批处理大小的问题。

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

Client：修复当达到最大订阅数时执行的无用重试的问题。

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

Functions

Functions：启用服务器端路由以存储状态。

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

Functions：传递来自 Pulsar source 的记录属性。

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

Schema

Schema：裸露 struct schema 的原始记录。

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

Schema：修复当 consumer 订阅没有 shcema 的空 topic 时，未增加 schema 的问题。

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

Schema：增加 schema 类型验证。

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

Schema：修复因 SchemaInfo 属性为空而引起的 NPE 问题。

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

Schema：修复由 topic 应用 schema KeyValue <GenericRecord, Gen​​ericRecord> 引起的 OutOfMemoryError 谬误。

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

其余

Maven：增加 jersey-client 作为 pulsar-client-auth-sasl 的依赖。

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

Build：修复在 Docker 中构建 wheel 文件时可能呈现的名称不匹配的谬误。

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

Flaky test：修复 CurrentLedgerRolloverIfFullTest flaky test。

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

Transactions：修复 transaction 日志的追加同步问题。

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

Topic：当禁用主动创立性能时，仍能够主动创立 topic partition。

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

Consumer：删除断开连接的 consumer，以进行主动发现。

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

Pulsar-perf：修复 pulsar-perf CLI 工具，确保与以前版本的兼容。

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

CI：修复 transaction flaky test。

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

Build：修复 ahc-default.properties 文件的暗影。

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

技术干货

  • Taking an In-Depth Look at How to Achieve Isolation in Pulsar
  • How To Get Started With Apache Pulsar On Docker
  • 译文 | Apache Pulsar 集群如何确保音讯不丢
  • Apache Pulsar 在能源互联网畛域的落地实际
  • StreamNative 发表开源 AWS SQS Connector
  • Apache BookKeeper 4.13.0 公布
  • 博文举荐|Pulsar 存储空间不开释的问题剖析与解决办法
  • 译文|抉择 Apache Pulsar 而非 Kafka 的 10 个理由

  • Apache Pulsar PMC 成员翟佳：Pulsar 2021 瞻望与布局

    • 博文举荐 | 一文带你看懂 Pulsar 的音讯保留和过期策略
    • 博文举荐|深度解析如何在 Pulsar 中实现隔离
    • 译文|借助 Pulsar Functions 迁徙到无服务应用程序

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

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

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

相干浏览

  • 脉冲星 2 月脉动 | Pulsar 的正月
  • 脉冲星 1 月脉动 | Pulsar Flink Connector 2.7.0 公布
正文完
消息队列
发表至： 消息队列
2021-04-02
 0
Spring整合RabbitMQ
关于消息队列:消息队列面试热点一锅端
关于消息队列:用-logstash-从-kafka-读取数据写入-Elasticsearchqbit
关于消息队列:mq从零开始实现-mq12消息的批量发送与回执