> ## 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
> Synchronisez les événements personnalisés de Confluent Cloud vers OneSignal pour déclencher des parcours automatisés et des campagnes de messagerie personnalisées basées sur le comportement utilisateur en temps réel.
export const DATA_TYPE_0 = undefined
export const PLATFORM_0 = "Confluent Cloud"
export const COLUMN_HEADER_0 = undefined
export const PROPERTIES_DESCRIPTION_0 = undefined
## Vue d'ensemble
L'intégration OneSignal + Confluent Cloud permet la synchronisation automatique des événements personnalisés depuis vos topics Kafka gérés vers OneSignal. Cela vous permet de déclencher des parcours automatisés et des campagnes de messagerie personnalisées basées sur les données comportementales des utilisateurs en temps réel circulant via votre plateforme de streaming Confluent Cloud.
***
## Prérequis
* Accès aux [Event Streams](/docs/en/event-streams) pour les événements de message sortants (Les limitations de forfait et les dépassements s'appliquent)
* Accès aux [Événements personnalisés](/docs/en/custom-events) pour la synchronisation des événements entrants (Les limitations de forfait et les dépassements s'appliquent)
* [Forfait de compte mis à jour](https://onesignal.com/pricing) (non disponible sur les applications gratuites)
### Confluent Cloud
* **Cluster Confluent Cloud** avec topics actifs
* **Identifiants API** avec accès en lecture aux topics d'événements
* **Schema Registry** (optionnel, pour les schémas d'événements structurés)
* **Topics d'événements** contenant des données comportementales avec format de message approprié
***
## Configuration
Générez des identifiants API pour OneSignal dans votre console Confluent Cloud :
1. Accédez à **Data Integration > API Keys** dans Confluent Cloud
2. Cliquez sur **Create key** et sélectionnez **Global access**
3. Enregistrez la **API Key** et le **API Secret** (vous en aurez besoin pour OneSignal)
4. Notez votre endpoint **Bootstrap servers** depuis les paramètres de votre cluster
Accordez à OneSignal l'accès en lecture à des topics spécifiques contenant des données d'événements :
```bash theme={null}
confluent kafka acl create \
--allow \
--service-account \
--operation READ \
--topic
confluent kafka acl create \
--allow \
--service-account \
--operation DESCRIBE \
--topic
```
Dans OneSignal, allez dans **Data > Integrations** et cliquez sur **Add Integration**.
Sélectionnez **Confluent Cloud** et fournissez :
* **Bootstrap Servers** : L'endpoint de votre cluster Confluent Cloud
* **API Key** : Clé API Confluent Cloud
* **API Secret** : Secret API Confluent Cloud
* **Consumer Group** : ID de groupe unique pour OneSignal (par ex., `onesignal-events`)
* **Schema Registry URL** (optionnel) : Si vous utilisez Confluent Schema Registry
Spécifiez les topics Confluent Cloud contenant vos données d'événements :
* **Topic Names** : Liste de topics séparés par des virgules à consommer (par ex., `user-events,purchase-events`)
* **Event Format** : Format de message JSON, Avro ou Protobuf
* **Schema Registry** : Activez si vous utilisez des schémas structurés
Vos messages d'événements doivent contenir :
* Nom/type d'événement (String)
* Identifiant utilisateur (String)
* Horodatage d'événement (Long/format ISO)
* Propriétés d'événement supplémentaires (JSON imbriqué)
Cliquez sur **Tester la connexion** pour vérifier que OneSignal peut se connecter à votre cluster Confluent Cloud et consommer les messages d'événements.
***
### Mappage des données d'événement
Mappez vos {DATA_TYPE_0} {PLATFORM_0} au format des événements personnalisés de OneSignal :
| Champ OneSignal | {COLUMN_HEADER_0} | Description | Requis |
| --------------- | ----------------- | ------------------------------- | ------ |
| `name` | `event_name` | Identifiant de l'événement | Oui |
| `external_id` | `user_id` | Identifiant de l'utilisateur | Oui |
| `timestamp` | `event_timestamp` | Quand l'événement s'est produit | Non |
| `properties` | `event_data` | {PROPERTIES_DESCRIPTION_0} | Non |
***
## Configuration avancée
### Intégration Schema Registry
Exploitez Confluent Schema Registry pour les données d'événements structurées :
```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"
}
}
}
```
### Gestion du groupe de consommateurs
OneSignal crée un groupe de consommateurs dédié pour suivre les offsets de messages :
* **Auto-commit** : Offsets validés automatiquement après traitement réussi
* **Gestion des erreurs** : Messages échoués enregistrés avec mécanisme de réessai
* **Mise à l'échelle** : Partitions équilibrées entre les instances de consommateurs OneSignal
### Traitement en temps réel
Confluent Cloud permet l'activation d'événements en quasi temps réel :
* **Faible latence** : Événements traités en quelques secondes après publication
* **Débit élevé** : Gère des milliers d'événements par seconde
* **Tolérance aux pannes** : Réplication intégrée et basculement automatique
Assurez-vous que votre cluster Confluent Cloud dispose d'une capacité de débit suffisante pour gérer le taux de consommation de OneSignal parallèlement à vos autres consommateurs.
***
## FAQ
### À quelle fréquence OneSignal consomme-t-il les événements depuis Confluent Cloud ?
OneSignal consomme les événements en temps réel dès leur arrivée dans vos topics, avec une latence minimale (généralement moins de 5 secondes).
### Puis-je consommer depuis plusieurs topics simultanément ?
Oui, OneSignal peut consommer depuis plusieurs topics en parallèle. Spécifiez les noms de topics sous forme de liste séparée par des virgules dans la configuration.
### Que se passe-t-il si OneSignal ne peut pas se connecter à Confluent Cloud ?
OneSignal réessaiera les connexions avec un backoff exponentiel. La consommation d'événements reprendra automatiquement une fois la connectivité rétablie.