写点什么

Apache Pulsar 2.0 支持模式注册表和主题压缩

  • 2018 年 6 月 27 日
  • 本文字数:1070 字

    阅读完需:约 4 分钟

最新版本的开源分布式消息传递框架 Apache Pulsar 让企业能够实时处理数据,从而“超越了批次处理”。 Streamlio 最近宣布推出 Apache Pulsar 2.0.1 流式消息解决方案。最新版本支持 Pulsar Function、模式注册表和主题压缩。

新版本的其他特性包括:

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

2018 年 6 月 27 日 03:59658
用户头像

发布了 731 篇内容, 共 387.2 次阅读, 收获喜欢 1914 次。

关注

评论

发布
暂无评论
发现更多内容

不可不知的 7 个 JDK 命令

武培轩

Java 程序员 jdk 后端 JVM

Flink源码分析之Flink startupMode是如何起作用的

shengjk1

flink flink 消费 kafak 实时计算 flink源码 flink源码分析

人人都是产品经理

二鱼先生

产品经理 个人品牌 职场成长 产品思维

每周学习总结-架构师培训一期

Damon

食堂就餐卡管理系统

孙志平

食堂就餐卡系统设计

饶军

架构师训练营-每周学习总结1

水边

极客大学架构师训练营

Flink源码分析之FlinkConsumer是如何保证一个partition对应一个thread的

shengjk1

flink flink 消费 kafka 实时计算 flink源码分析

dnsmasq-域名访问及解析缓存

一周思进

ARTS打卡 week 2

猫吃小怪兽

ARTS 打卡计划

愚蠢写作术(3):如何把读者带入迷宫深处

史方远

学习 读书笔记 个人成长 写作

SpringBatch系列之并发并行能力

稻草鸟人

Spring Boot SpringBatch 批量

程序员陪娃系列——数学启蒙趣事

孙苏勇

程序员 陪伴

UML练习1 食堂就餐卡系统设计「架构师训练营」

Young

因为 MongoDB 没入门,我丢了一份实习工作

沉默王二

mongodb

Flink源码分析之Flink是如何kafka读取数据的

shengjk1

flink flink 消费 kafka flink源码分析 flink消费kafka源码解析

极客时间-架构师培训-1期作业

Damon

Element-UI实战系列:Tree组件的几种使用场景

brave heart

vue.js 大前端 Elemen

架构师训练营第一周作业

小树林

食堂就餐卡系统设计

飞雪

利其器

宋胖子

IDEA

Java 25周年:波澜壮阔的25年

北风

「Java 25周年」

Flink源码分析之Flink 自定义source、sink 是如何起作用的

shengjk1

flink flink源码 flink源码分析 flink自定义source flink自定义sink

架构师如何做架构总结

Karl

Flink源码分析之-如何保存 offset

shengjk1

架构师训练营第一周作业

芒夏

极客大学架构师训练营

食堂就餐卡系统架构设计

Karl

【ARTS打卡】Week02

Rex

架构师训练营-命题作业1

水边

极客大学架构师训练营

ARTS-WEEK2

一周思进

ARTS 打卡计划

架构师训练营第一周学习总结

刘志刚

ShadowRealm 与微前端沙箱

ShadowRealm 与微前端沙箱

Apache Pulsar 2.0支持模式注册表和主题压缩-InfoQ