> ## Documentation Index
> Fetch the complete documentation index at: https://documentation.onesignal.com/llms.txt
> Use this file to discover all available pages before exploring further.
# Confluent Cloud
> Sincronice eventos personalizados desde Confluent Cloud a OneSignal para activar Journeys automatizados y campañas de mensajería personalizadas basadas en el comportamiento del usuario en tiempo real.
export const DATA_TYPE_0 = undefined
export const PLATFORM_0 = "Confluent Cloud"
export const COLUMN_HEADER_0 = undefined
export const PROPERTIES_DESCRIPTION_0 = undefined
## 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
* Acceso a [flujos de eventos](/docs/es/event-streams) para eventos de mensajes salientes (Se aplican limitaciones del plan y sobrecargos)
* Acceso a [eventos personalizados](/docs/es/custom-events) para sincronización de eventos entrantes (Se aplican limitaciones del plan y sobrecargos)
* [Plan de cuenta actualizado](https://onesignal.com/pricing) (no disponible en aplicaciones gratuitas)
### 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
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
Otorgue a OneSignal acceso de lectura a temas específicos que contengan datos de eventos:
```bash theme={null}
confluent kafka acl create \
--allow \
--service-account \
--operation READ \
--topic
confluent kafka acl create \
--allow \
--service-account \
--operation DESCRIBE \
--topic
```
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
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)
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 {DATA_TYPE_0} de {PLATFORM_0} al formato de eventos personalizados de OneSignal:
| Campo de OneSignal | {COLUMN_HEADER_0} | Descripción | Requerido |
| ------------------ | ----------------- | -------------------------- | --------- |
| `name` | `event_name` | Identificador de evento | Sí |
| `external_id` | `user_id` | Identificador de usuario | Sí |
| `timestamp` | `event_timestamp` | Cuándo ocurrió el evento | No |
| `properties` | `event_data` | {PROPERTIES_DESCRIPTION_0} | No |
***
## Configuración avanzada
### Integración de Schema Registry
Aproveche Confluent Schema Registry para datos de eventos estructurados:
```json theme={null}
{
"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.