58 同城基于 Flink 的千亿级实时计算平台架构实践 本文由 dbaplus 社

58 同城作为覆盖生活全领域的服务平台，业务覆盖招聘、房产、汽车、金融、二手及本地服务等各个方面。丰富的业务线和庞大的用户数每天产生海量用户数据需要实时化的计算分析，实时计算平台定位于为集团海量数据提供高效、稳定、分布式实时计算的基础服务。本文主要介绍 58 同城基于 Flink 打造的一站式实时计算平台 Wstream。实时数据 ETL：实时消费 Kafka 数据进行清洗、转换、结构化处理用于下游计算处理。Flink 作为实时计算集群，可用性要求远高于离线计算集群。