Ana içeriğe atla

​
Genel Bakış

OneSignal + Confluent Cloud entegrasyonu, yönetilen Kafka konularınızdan OneSignal’a özel olayların otomatik senkronizasyonunu sağlar. Bu, Confluent Cloud akış platformunuz aracılığıyla akan gerçek zamanlı kullanıcı davranışsal verilerine dayalı olarak otomatik Journey’leri ve kişiselleştirilmiş mesajlaşma kampanyalarını tetiklemenize olanak tanır.

​
Gereksinimler

​
Confluent Cloud

  • Etkin konular içeren Confluent Cloud kümesi
  • Olay konularına okuma erişimi olan API kimlik bilgileri
  • Schema Registry (isteğe bağlı, yapılandırılmış olay şemaları için)
  • Uygun mesaj formatı ile davranışsal veriler içeren Olay konuları

​
Kurulum

1

Confluent Cloud'da API kimlik bilgileri oluşturun

Confluent Cloud konsolunuzda OneSignal için API kimlik bilgileri oluşturun:
  1. Confluent Cloud’da Veri Entegrasyonu > API Anahtarları’na gidin
  2. Anahtar oluştur’a tıklayın ve Genel erişim’i seçin
  3. API Anahtarı ve API Secret’ı kaydedin (OneSignal için bunlara ihtiyacınız olacak)
  4. Küme ayarlarınızdan Bootstrap sunucuları uç noktanızı not edin
2

Konu ACL'lerini yapılandırın (ayrıntılı izinler kullanılıyorsa)

OneSignal’a olay verileri içeren belirli konulara okuma erişimi verin:
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

OneSignal'da entegrasyon ekleyin

In OneSignal, go to Data > Integrations and click Add Integration.Confluent Cloud’u seçin ve şunları sağlayın:
  • Bootstrap Servers: Confluent Cloud küme uç noktanız
  • API Key: Confluent Cloud API anahtarı
  • API Secret: Confluent Cloud API secret
  • Consumer Group: OneSignal için benzersiz grup kimliği (örn., onesignal-events)
  • Schema Registry URL (isteğe bağlı): Confluent Schema Registry kullanılıyorsa
4

Olay konularını yapılandırın

Olay verilerinizi içeren Confluent Cloud konularını belirtin:
  • Topic Names: Tüketilecek konuların virgülle ayrılmış listesi (örn., user-events,purchase-events)
  • Event Format: JSON, Avro veya Protobuf mesaj formatı
  • Schema Registry: Yapılandırılmış şemalar kullanılıyorsa etkinleştirin
Olay mesajlarınız şunları içermelidir:
  • Olay adı/türü (String)
  • Kullanıcı tanımlayıcısı (String)
  • Olay zaman damgası (Long/ISO formatı)
  • Ek olay özellikleri (iç içe JSON)
5

Bağlantıyı test edin

OneSignal’ın Confluent Cloud kümenize bağlanabileceğini ve olay mesajlarını tüketebileceğini doğrulamak için Bağlantıyı Test Et’e tıklayın.

​
Event data mapping

Map your to OneSignal’s custom events format:
OneSignal FieldDescriptionRequired
nameevent_nameEvent identifierYes
external_iduser_idUser identifierYes
timestampevent_timestampWhen event occurredNo
propertiesevent_dataNo

​
Gelişmiş Yapılandırma

​
Schema Registry Entegrasyonu

Yapılandırılmış olay verileri için Confluent Schema Registry’den yararlanın: 
{
  "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"
    }
  }
}

​
Tüketici Grubu Yönetimi

OneSignal, mesaj ofsetlerini izlemek için özel bir tüketici grubu oluşturur:
  • Otomatik commit: Başarılı işlemeden sonra ofsetler otomatik olarak commit edilir
  • Hata İşleme: Başarısız mesajlar yeniden deneme mekanizması ile günlüğe kaydedilir
  • Ölçekleme: Bölümler OneSignal tüketici örnekleri arasında dengelenir

​
Gerçek Zamanlı İşleme

Confluent Cloud, neredeyse gerçek zamanlı olay aktivasyonunu sağlar:
  • Düşük Gecikme: Olaylar yayınlandıktan saniyeler içinde işlenir
  • Yüksek Verim: Saniyede binlerce olayı işler
  • Hata Toleransı: Yerleşik çoğaltma ve otomatik yük devretme
Confluent Cloud kümenizin, diğer tüketicilerinizin yanı sıra OneSignal’ın tüketim hızını işlemek için yeterli verim kapasitesine sahip olduğundan emin olun.

​
SSS

​
OneSignal Confluent Cloud’dan olayları ne sıklıkta tüketir?

OneSignal, olayları konularınıza ulaştıkça gerçek zamanlı olarak tüketir, minimum gecikme ile (genellikle 5 saniyenin altında).

​
Aynı anda birden fazla konudan tüketebilir miyim?

Evet, OneSignal birden fazla konuyu paralel olarak tüketebilir. Yapılandırmada konu adlarını virgülle ayrılmış liste olarak belirtin.

​
OneSignal Confluent Cloud’a bağlanamıyorsa ne olur?

OneSignal, üstel geri çekilme ile bağlantıları yeniden deneyecektir. Bağlantı geri yüklendiğinde olay tüketimi otomatik olarak devam eder.