米其林、汉莎航空使用Kafka数据流的案例

售后销售和客户服务需要在正确的时间获得正确的信息来做出针对具体情况的决策。使用 Apache Kafka 进行数据流处理可实现真正的解耦、领域驱动设计以及跨实时和批处理系统的数据一致性。共同的业务目标推动着他们：提高客户保留率、增加收入、降低成本并缩短创新上市时间。

米其林通过数据流改善售后销售和客户服务
售后市场是制造业的二级市场，涉及原始设备制造商（OEM）将产品销售给消费者后所有零件、化学品、设备和配件的生产、分销、零售和安装。“售后市场”一词主要用于汽车行业，但也适用于其他制造业。

企业利用数据流从汽车、经销商、客户和许多其他后端系统收集数据，以便在相关（预测性维护）或有价值（交叉/追加销售）时实时做出自动化的特定于上下文的决策。

制造商在寻求实施售后服务数字工具时面临许多挑战。麦肯锡将研究要点定义为五个中心优先事项（全部以数据为基础），以改善售后服务：人员、运营、报价、外部合作伙伴网络和数字工具。

数据流通过实时数据集成和关联来做出针对具体情况的决策，有助于改变全球供应链，包括售后业务流程。

米其林是一家法国跨国轮胎制造公司，生产几乎所有类型的车辆。该公司销售多种轮胎。他们生产汽车、摩托车、自行车、飞机、航天飞机和重型设备的产品。

米其林的许多发明包括可拆卸轮胎、“pneurail”（用于橡胶轮胎地铁的轮胎）和子午线轮胎。

米其林在卡夫卡峰会上介绍了他们如何从整体编排器转向微服务数据流。该项目的目的是更换一个巨大而复杂的业务流程管理工具（Oracle BPM），它是内部物流的协调器。

当米其林说“巨大”时，他们是认真的：超过 24 个流程，1.5 亿条轮胎被移动，代表着 100 亿欧元的米其林营业额。那么为什么要更换信息系统中如此关键的组件呢？主要是因为“它像一个整体 ERP 一样构建，并且变得难以维护，更不用说潜在的单点故障了”。米其林 用围绕我们的 Kafka 集群编排的微服务取代了它。

米其林与大多数制造商面临着同样的挑战：数据处理缓慢、信息冲突和供应链复杂。因此，米其林从意大利面条式集成架构和批处理转向解耦微服务和实时事件驱动架构。

他们通过连接供应链中的各种系统（包括 DRP、TMS、ERP、WMS 等）优化了不可靠且过时的库存报告，特别是原材料和半成品的库存报告。

然而，供应链并不止于制造最好的轮胎。米其林旨在通过数据驱动的分析提供最佳的服务和客户体验。作为该计划的一部分，米其林从传统 BPM 引擎的编排和单点故障迁移到灵活的编排和利用 Apache Kafka 的事件驱动架构的真正解耦

米其林实施了移动解决方案，为其多元化的客户群提供移动协助和车队服务。例如，预测洞察会通知客户更换轮胎或显示优化燃油的最佳路线。新的业务流程编排可实现主动营销和售后。由于事件驱动的架构可以在正确的时间（例如，当客户拨打服务热线时）访问正确的数据，因此可以实现特定于上下文的客户服务。

技术基础设施基于云原生技术，例如 Kubernetes（弹性基础设施）、Apache Kafka（具有 Kafka Connect 和 Kafka Streams 等组件的数据流）和 Zeebe（现代 BPM 和工作流引擎）。

汉莎航空使用 Apache Kafka 进行中间件和分析
众所周知，航空和旅行很容易受到社会、经济和政治事件以及消费者不断变化的期望的影响。

航空公司和机场的未来业务将以 数字方式融入 合作伙伴和供应商的生态系统中。公司将提供 更加个性化的客户体验 ，并通过一系列最新技术（包括自动化、机器人技术和生物识别技术）来实现。

整个航空业已经在利用由 Apache Kafka 提供支持的数据流。这包括航空公司、机场、全球分销系统 (GDS)、飞机制造商、旅行社等。为什么？因为在几乎所有用例中，实时数据都击败了慢速数据。

Apache Kafka 作为下一代中间件取代 ETL、ESB 和 iPaaS
通常，企业服务总线（ESB）或其他集成解决方案（例如提取-转换-加载（ETL）工具）已被用来尝试解耦系统。然而，连接器的数量之多，以及应用程序同时发布和订阅数据的要求，意味着系统总是交织在一起。导致开发项目依赖于其他系统，无法真正解耦。

许多企业利用 Apache Kafka 生态系统成功集成不同的遗留和现代应用程序。数据流有所不同，但也补充了现有的集成解决方案，例如 ESB 或 ETL 工具。Apache Kafka 是独一无二的，因为它将以下特征组合到一个中间件平台中：

• 任何规模的实时消息传递
• 事件存储用于历史事件的真正解耦、背压处理和可重玩性
• 数据集成无需额外的集成工具
• 实时和历史数据的无状态和有状态数据关联的流处理

汉莎航空利用Confluence 的数据流作为其战略集成项目 KUSCO（Kafka 统一流云操作）的云原生中间件。
该团队讨论了使用 Apache Kafka 代替传统消息队列（TIBCO EMS、IBM MQ）进行数据处理的好处。我最喜欢的两句话：

• “扩展 Kafka 真的很便宜”
• “Kafka 在 3 个月内被采用并集成”

汉莎航空利用 KUSCO 平台利用关键工作负载的实时数据构建新的分析用例。在网络研讨会中，我们从汉莎集团的领域架构师 Sebastian Weber 那里了解了以下两个项目：警报异常检测和飞机运营机队管理。

数据从各种数据源输入流媒体平台。在分析应用程序进行实时警报之前，汉莎航空通过流处理来整合和聚合数据。

用于实时车队管理的机器学习和 Apache Kafka:汉莎航空利用流平台作为数据结构来进行数据摄取、数据处理和模型评分。

汉莎航空向我们展示了如何在航空业中进行创新，快速将产品推向市场，同时仍与传统技术相集成。这两个项目展示了截然不同的挑战和使用由 Apache Kafka 生态系统支持的数据流解决的用例。

航空业正在迅速变化。良好的客户体验、有价值的忠诚度平台和有竞争力的定价（或更好的软硬产品）需要端到端供应链的数字化。这包括工业物联网（例如预测性维护）、与合作伙伴（例如 GDS、机场和零售商）的 B2B 通信以及客户 360（包括出色的移动应用程序和全渠道体验）等主题。