这篇文章是由Azure消息（事件中心）项目经理Shubha Vijayasarathy共同撰写的MileIQ记录了数十亿英里，为数百万司机提供了无压力的记录和准确的里程报告。对于那些需要开车上班的员工的组织，独立承包商必须记录和报告行驶里程。MileIQ自动记录里程，以创建行驶里程的准确记录，最大限度地减少人工计算所需的工作量和时间。实时里程跟踪每小时产生超过100万个位置信号事件，需要快速和有弹性的事件处理。MileIQ利用Apache Kafka来接收大量数据流：事件处理：需要耗时处理的事件被放入Kafka中，多个处理器异步地消费和处理这些事件。微服务间的通信：事件由拥有微服务的事件发布，主题为Kafka。其他对这些事件感兴趣的微服务订阅这些主题来使用这些事件。数据分析：由于所有重要事件都发布在Kafka上，数据分析团队订阅其感兴趣的主题，并提取数据处理所需的所有数据。增长挑战与任何成功的企业一样，随着基础设施难以满足不断增长的需求，增长带来了运营挑战。在MileIQ的例子中，维护apachekafka集群所需的精力和资源随着采用而成倍增加。一项看似简单的任务，比如修改主题的保留配置，现在却成了操作上的负担，因为Kafka集群的数量在不断扩展以满足数据的增长。利用托管服务，MileIQ能够将资源从运营和维护转移到专注于推动业务影响的新方法上。MileIQ团队为Kafka选择Azure事件中心的原因如下：完全管理的平台即服务（PaaS）：由于配置或管理开销很少，Kafka事件中心提供了PaaS-Kafka体验，而无需管理、配置或运行Kafka群集。支持多个Kafka用例：ApacheKafka事件中心在协议级别提供支持，支持在不更改代码和最小配置更改的情况下集成现有Kafka应用程序。MileIQ现有的Kafka生产商和消费者，以及其他流媒体应用程序，如ApacheKafka MirrorMaker和ApacheSpark，与支持Kafka的事件中心无缝集成。向Azure Blob存储交付流数据：事件中心的捕获功能自动将数据从用于Kafka的Azure事件中心发送到Blob存储。MileIQ使用Blob存储中的数据进行数据分析和备份。企业性能：专用层集群提供单租户部署，保证99.99%的SLA。MileIQ性能测试表明，专用层集群能够始终如一地产生每秒6000个事件的吞吐量。*基于一次一个事件的同步测试，以解决特定的用例，关注于吞吐量上的一致性。测试批处理和异步生产导致了更高的吞吐量。为成功做好准备由于将Apache-Kafka迁移到托管服务，MileIQ现在拥有了支持未来增长所需的基础设施。"总而言之，我们切换到Azure Event Hubs Kafka的体验非常棒。首先，入职很简单，集成是无缝的，我们继续从Azure Event Hubs Kafka团队获得极大的帮助和支持。在不久的将来，我们期待着Azure Event Hubs Kafka团队正在开发的新功能的发布——地理复制、幂等生产者、Kafka流等。""迁移到Azure事件中心Kafka是一次无痛的经历。直接的入职无缝集成，以及活动中心团队每一步的支持。我们很高兴看到下一步，并期待着继续合作。"—MileIQ数据流启动只有当有一种简单的方法来处理和及时地从数据源获得见解时，数据才是有价值的。azureeventhubs提供了一个完全管理的分布式流处理平台，具有低延迟和与apachekafka应用程序的无缝集成。你还在等什么？是时候开始活动了！ApacheKafka事件中心概述入门：创建支持Apache-Kafka的事件集线器了解有关Azure事件中心的更多信息了解专用层群集喜欢这个博客吗？请跟随我们更新我们将开始支持的功能列表。请在下面给我们留下您宝贵的反馈、问题或意见。活动愉快！