Saltar al contenido principal

​
Descripción general

La integración de OneSignal + Confluent Cloud permite la sincronización automática de eventos personalizados desde sus temas de Kafka administrados a OneSignal. Esto le permite activar Journeys automatizados y campañas de mensajería personalizadas basadas en datos de comportamiento del usuario en tiempo real que fluyen a través de su plataforma de streaming de Confluent Cloud.

​
Requisitos

​
Confluent Cloud

  • Clúster de Confluent Cloud con temas activos
  • Credenciales de API con acceso de lectura a los temas de eventos
  • Schema Registry (opcional, para esquemas de eventos estructurados)
  • Temas de eventos que contengan datos de comportamiento con el formato de mensaje adecuado

​
Configuración

1

Crear credenciales de API en Confluent Cloud

Genere credenciales de API para OneSignal en su consola de Confluent Cloud:
  1. Navegue a Data Integration > API Keys en Confluent Cloud
  2. Haga clic en Create key y seleccione Global access
  3. Guarde la API Key y el API Secret (los necesitará para OneSignal)
  4. Anote su endpoint de Bootstrap servers desde la configuración de su clúster
2

Configurar ACLs de temas (si usa permisos granulares)

Otorgue a OneSignal acceso de lectura a temas específicos que contengan datos de eventos:
confluent kafka acl create \
  --allow \
  --service-account <ONESIGNAL_SERVICE_ACCOUNT_ID> \
  --operation READ \
  --topic <EVENT_TOPIC_NAME>

confluent kafka acl create \
  --allow \
  --service-account <ONESIGNAL_SERVICE_ACCOUNT_ID> \
  --operation DESCRIBE \
  --topic <EVENT_TOPIC_NAME>
3

Agregar integración en OneSignal

En OneSignal, vaya a Datos > Integraciones y haga clic en Agregar integración.Seleccione Confluent Cloud y proporcione:
  • Bootstrap Servers: El endpoint de su clúster de Confluent Cloud
  • API Key: Clave de API de Confluent Cloud
  • API Secret: Secreto de API de Confluent Cloud
  • Consumer Group: ID de grupo único para OneSignal (por ejemplo, onesignal-events)
  • Schema Registry URL (opcional): Si usa Confluent Schema Registry
4

Configurar temas de eventos

Especifique los temas de Confluent Cloud que contienen sus datos de eventos:
  • Topic Names: Lista separada por comas de temas a consumir (por ejemplo, user-events,purchase-events)
  • Event Format: Formato de mensaje JSON, Avro o Protobuf
  • Schema Registry: Habilite si usa esquemas estructurados
Sus mensajes de eventos deben contener:
  • Nombre/tipo de evento (String)
  • Identificador de usuario (String)
  • Marca de tiempo del evento (formato Long/ISO)
  • Propiedades adicionales del evento (JSON anidado)
5

Probar la conexión

Haga clic en Test Connection para verificar que OneSignal pueda conectarse a su clúster de Confluent Cloud y consumir mensajes de eventos.

​
Mapeo de datos de eventos

Mapee su de al formato de eventos personalizados de OneSignal:
Campo de OneSignalDescripciónRequerido
nameevent_nameIdentificador de eventoSí
external_iduser_idIdentificador de usuarioSí
timestampevent_timestampCuándo ocurrió el eventoNo
propertiesevent_dataNo

​
Configuración avanzada

​
Integración de Schema Registry

Aproveche Confluent Schema Registry para datos de eventos estructurados: 
{
  "schema": "user_event_schema_v1",
  "data": {
    "event_name": "purchase",
    "user_id": "user_12345",
    "event_timestamp": 1640995200000,
    "properties": {
      "product_id": "prod_abc123",
      "amount": 29.99,
      "currency": "USD"
    }
  }
}

​
Gestión de grupos de consumidores

OneSignal crea un grupo de consumidores dedicado para rastrear los desplazamientos de mensajes:
  • Auto-commit: Desplazamientos confirmados automáticamente después del procesamiento exitoso
  • Manejo de errores: Mensajes fallidos registrados con mecanismo de reintento
  • Escalado: Particiones equilibradas entre instancias de consumidores de OneSignal

​
Procesamiento en tiempo real

Confluent Cloud permite la activación de eventos casi en tiempo real:
  • Baja latencia: Eventos procesados en segundos después de ser publicados
  • Alto rendimiento: Maneja miles de eventos por segundo
  • Tolerancia a fallos: Replicación integrada y conmutación por error automática
Asegúrese de que su clúster de Confluent Cloud tenga suficiente capacidad de rendimiento para manejar la tasa de consumo de OneSignal junto con sus otros consumidores.

​
Preguntas frecuentes

​
¿Con qué frecuencia OneSignal consume eventos de Confluent Cloud?

OneSignal consume eventos en tiempo real a medida que llegan a sus temas, con latencia mínima (típicamente menos de 5 segundos).

​
¿Puedo consumir de múltiples temas simultáneamente?

Sí, OneSignal puede consumir de múltiples temas en paralelo. Especifique los nombres de los temas como una lista separada por comas en la configuración.

​
¿Qué sucede si OneSignal no puede conectarse a Confluent Cloud?

OneSignal reintentará las conexiones con retroceso exponencial. El consumo de eventos se reanudará automáticamente una vez que se restaure la conectividad.