Passer au contenu principal

​
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 pour les événements de message sortants (Les limitations de forfait et les dépassements s’appliquent)
  • Accès aux Événements personnalisés pour la synchronisation des événements entrants (Les limitations de forfait et les dépassements s’appliquent)
  • Forfait de compte mis à jour (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

1

Créer des identifiants API dans Confluent Cloud

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
2

Configurer les ACL de topic (si vous utilisez des autorisations granulaires)

Accordez à OneSignal l’accès en lecture à des topics spécifiques contenant des données d’événements :
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

Ajouter l'intégration dans OneSignal

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
4

Configurer les topics d'événements

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é)
5

Tester la connexion

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 au format des événements personnalisés de OneSignal :
Champ OneSignalDescriptionRequis
nameevent_nameIdentifiant de l’événementOui
external_iduser_idIdentifiant de l’utilisateurOui
timestampevent_timestampQuand l’événement s’est produitNon
propertiesevent_dataNon

​
Configuration avancée

​
Intégration Schema Registry

Exploitez Confluent Schema Registry pour les données d’événements structurées : 
{
  "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.