【ApacheCon North America 2019】Ap

# 【ApacheCon North America 2019】Apache Pulsar 演讲预览

九月，拉斯维加斯，ApacheCon North America 2019，Apache Pulsar 在美国等你。以下是 Pulsar 相关的会议主题和简介，欢迎感兴趣的小伙伴持续关注。

## 基于 Apache Pulsar 构建智联招聘企业级事件总线

翟佳&李鹏辉

原文链接: <u>https://apachecon.com/acna19/s/#/scheduledEvent/1189</u>

智联招聘（Zhaopin.com）是一家中国的在线招聘服务提供商，招聘广告来自全国各地的中外知名公司和企业，平台采用双语招聘信息，是国内实时空缺职位选择最多的平台。智联招聘为 220 万+客户提供专业的人力资源服务，平均每日综合浏览量超过 6800 万。

Apache Pulsar 开发旨在解决现有消息系统的很多痛点，包括支持更多企业功能、消息持久性和消息的低延迟。多年来智联招聘一直使用 RabbitMQ 建立企业事件总线。随着公司发展，数据量越来越大，消息系统的使用场景也变得多样化，原来基于 RabbitMQ 的架构无力支持现有的业务。最终在 2018 年，智联招聘选择 Apache Pulsar 取代 RabbitMQ 架构。自 2018 年 8 月部署 Apache Pulsar 以来，Pulsar 的数据量从每天 3000 万条消息增加到 60 亿以上。通过研究大量实践经验，我们总结了使用 Pulsar 作为企业事件总线的最佳实践。

鹏辉和翟佳将详细介绍 Apache Pulsar 如何满足智联招聘的需求、智联招聘如何使用 Pulsar，以及将 Pulsar 用作企业事件总线的最佳实践。本次演讲会重点介绍 Apache Pulsar 的优势、高可用、高吞吐量和低延迟等特性，以及为何 Apache Pulsar 是企业事件总线的理想选择。

## 使用 Pulsar Functions 进行 Serverless 流计算：用户案例和最佳实践

冉小龙

原文链接: <u>https://apachecon.com/acna19/s/#/scheduledEvent/1193</u>

随着数据的不断发展，数据计算的要求不断变化。为满足用户需求，从 server 到 VMS，到容器，再到 serverless，计算框架在不断演进。如何为用户提供快速、易部署的计算框架已经成为一个难点。本次演讲将介绍 Pulsar 如何基于 serverless 计算架构提供强大的计算能力。Apache Pulsar 是新一代云消息系统和实时处理平台，消息系统与实时计算平台密切相关，但通常单独部署和管理。

作为 Pulsar 的计算组件，Pulsar Functions 是消息平台和计算平台在 serverless 方向上的融合和创新。Pulsar Functions 支持 Go、Python 和 Java 等多种语言，支持 Thread、Process 和 Kubernetes 运行环境，为用户编写、运行和部署功能提供了极大的灵活性。用户只需关心计算逻辑本身，而无需复杂的配置或管理，让构建消息触发式流平台变得简单。

## Life beyond Kafka with Apache Pulsar

Alvaro Santos Andrés

原文链接: <u>https://apachecon.com/acna19/s/#/scheduledEvent/1153</u>

在万物互联的世界中，数万亿台设备都在实时向数据中心发送数据。作为流数据平台，这么多年来，Apache Kafka 表现得还不错。 然而，随着诸多竞争对手的出现，Kafka 开始举步维艰。本次演讲介绍雅虎赞助的 Apache Pulsar，Pulsar 是下一代消息传递系统，使用不同架构实现持久性、可扩展性、高可用、低延迟、多租户和地域复制。此外，本次演讲还将重点介绍为什么 Apache Pulsar 流数据平台能在物联网项目中表现卓越。

## 使用 Apache Pulsar 实现流的交互查询

Boyang Jerry Peng

原文链接: <u>https://apachecon.com/acna19/s/#/scheduledEvent/1192</u>

随着应用程序对实时数据依赖程度的提高，消息流平台的使用越来越广泛，消息流平台对数据管道越来越重要。目前，许多消息流平台仅用于从数据流访问最新事件。然而，如果能以交互方式查询流的完整历史，就可以解锁更大的价值。Pulsar SQL 是一个建立在 Apache Pulsar（下一代消息平台）上的查询层，让用户能够动态查询存储在 Pulsar 内部的所有新旧流。因此，用户可以在一个系统中同时查询新数据流和历史数据流来解锁更多商业价值。Pulsar SQL 利用 Presto 和 Apache Pulsar 独特的架构，以高度可扩展的方式执行查询，而不受限于构成流的主题分区数量。本次演讲将研究在消息流平台中交互式查询事件的用例和优势，以及 Pulsar 如何以高效、易用的方式支持用户实现这一功能。

## 在边缘计算中使用 Apache Pulsar 提供实时 IoT 分析

David Kjerrumgaard

原文链接: <u>https://apachecon.com/acna19/s/#/scheduledEvent/1015</u>

数据自创建后，其商业价值迅速下降，尤其是在欺诈预防、网络安全和实时系统监控等场景中。这类用户场景通常产生海量、高速的数据集，需要立即挖掘出其中的价值。为了最大化数据价值，企业必须从根本上改变处理实时数据的方法，减少对实时数据流中稍纵即逝的商业价值（perishable insights）进行决策的延迟，从而使组织能够在最佳时刻采取行动。由于众多原因，在海量、高速数据环境中及时挖掘商业价值很有挑战。随着数据量的增加，数据传输回数据中心并进行处理所需的时间也会增加。其次，数据产生的速度越快，其商业价值消失的也越快。本次演讲就此问题提出一个基于 Apache Pulsar Functions 的解决方案，通过概率算法在边缘计算中执行分析计算，显著降低决策延迟。

StreamNative 成为 ApacheCon NA 2019 Hackathon Sponsor。

图片1.png

有关本次大会其他 sponsor，查看 (https://www.apachecon.com/acna19/sponsors.html)。