作者｜HaohuiMai,BillLiu,NaveenCherukuri译者｜核子可乐Uber公司通过传播各类实时来源数据以实现更加无缝化且令人愉悦的用户体验。具体而言，Uber需要交付UberEATS订单的预估交付时间（简称ETD）、结合即时交通条件得出的指导配送路线以及其间各项重要影响指标。来自Uber的几位优...(more)

Kafka起初是由LinkedIn公司开发的一个分布式的消息系统，后成为Apache的一部分，它使用Scala编写，以可水平扩展和高吞吐率而被广泛使用。目前越来越多的开源分布式处理系统如Cloudera、ApacheStorm、Spark等都支持与Kafka集成。1概述Kafka与传统消息系统相比，有以下不同：它被设...(more)

我们把这个系统叫做发布管道（PublishingPipeline）。这篇文章主要关注后端的系统，我们会介绍如何使用Kafka保存纽约时报的文章，以及如何使用Kafka和SteamsAPI将发布的内容实时推送给各种应用。下面是总体的架构图，具体细节稍后详述。微信图片_20170927093957.jpg基于API解决方...(more)

我非常高兴地宣布KSQL，这是面向ApacheKafka的一种数据流SQL引擎。KSQL降低了数据流处理这个领域的准入门槛，为使用Kafka处理数据提供了一种简单的、完全交互的SQL界面。你不再需要用Java或Python之类的编程语言编写代码了！KSQL具有这些特点：开源（采用Apache2.0许可证）、分布式...(more)