Airbnb desarrolló una plataforma de procesamiento de flujo llamada Plataforma de Señales de Usuario (USP) para mejorar la experiencia del usuario a través de la personalización. La plataforma aprovecha los datos de participación del usuario para proporcionar interacciones personalizadas durante el proceso de reserva. Consiste en una capa de tubería de datos y una capa de servicio en línea, con Flink de flujo para procesamiento en tiempo real cercano y procesamiento por lotes para corrección de datos y rellenado. USP admite varios procesamientos de eventos de usuario, incluyendo Señales de Usuario, Segmentos de Usuario y Compromisos de Sesión. También utiliza métricas como latencia de eventos, latencia de ingesta, latencia de trabajo y latencia de transformación para medir el rendimiento de los trabajos de flujo. La plataforma permite a los desarrolladores definir transformaciones y segmentos de usuario sin preocuparse por los componentes de flujo. Para mejorar la estabilidad de los trabajos de Flink, Airbnb utiliza administradores de tareas de respaldo para asegurar el procesamiento continuo cuando un administrador de tareas falla.