最新版本的开源分布式消息传递框架 Apache Pulsar 让企业能够实时处理数据，从而“超越了批次处理”。 Streamlio 最近宣布推出 Apache Pulsar 2.0.1 流式消息解决方案。最新版本支持 Pulsar Function、模式注册表和主题压缩。
新版本的其他特性包括：
- 将 Apache BookKeeper 升级到 4.7 版本
- 性能改进
- 与 Pulsar 2.0 之前的版本兼容
Pulsar Function：今年早些时候首次发布了这个原生流式处理能力的预览版。 Pulsar Function 是一种轻量级的计算进程，在数据流经 Pulsar 的时候，可直接用使用它们对数据进行变换和分析，无需借助外部系统或附件。每次有消息被发布到输入主题时，都会执行 Function。
模式注册表：模式注册表为开发人员提供定义和验证流经Pulsar 的数据的结构和完整性的能力，简化了数据驱动应用程序的开发。它提供了一个内置的注册表，让客户端可以基于主题上传数据模式。这些模式用于确定哪些数据类型对该主题是有效的。模式注册表当前仅适用于 Java 客户端。
主题压缩：Pulsar 使用 Apache Bookkeeper 保存流式数据，这一改进提升了存储性能。主题压缩是一个运行在Pulsar broker 上的进程，用于为主题中的每个键创建最新值的快照。主题压缩进程读取主题的积压消息，只保留每个键的最新值。它是非破坏性的，所以原始积压消息仍然可供用户使用。用户可以通过REST 端点手动触发它来控制何时进行主题压缩。
InfoQ 采访了 Streamlio 联合创始人和 Pulsar 架构师兼首席开发者 Matteo Merli，谈到了 Pulsar 架构及其产品路线图。
InfoQ：Pulsar 与其他消息框架相比如何？
Matteo Merli：与其他许多框架一样，Pulsar 提供了可以通过各种客户端进行访问的分布式消息传递能力。Pulsar 能够满足现代基于数据驱动的应用程序和数据分析的要求，却没有其他框架的成本和复杂性。更具体地说，这些功能包括更好的吞吐量和更低的延迟、可扩展性、原生流式函数处理以及对发布订阅消息和消息队列、多数据中心复制、安全和资源管理的支持。
InfoQ：Pulsar 的产品路线图是怎样的？即将推出哪些功能？
Merli：作为一个开源项目，Apache Pulsar 路线图是由 Pulsar 社区的贡献者和用户共同决定的。预计当前开发的版本很快会发布，包括对其他访问接口的支持、一组新的数据源和存储库连接器、增强的多层存储能力以及更多受支持的模式格式。
Pulsar 团队上周发布了 2.0.1 版本，其中包括对 PyPI 上的 Python 包以及由 Pulsar 代理提供的 REST API 的修复。有关新版本的更多信息，请查看 Pulsar 网站上的发行说明。
查看英文原文： Distributed Messaging Framework Apache Pulsar 2.0 Supports Schema Registry and Topic Compaction
暂无签名
Java 避坑指南：Java 高手笔记代码篇
本迷你书包括 86 个业务开发中常见踩坑点。每一个知识点都相当的实用，是程序员业务开发中的必备避坑指南...
评论