概览
OneSignal + Confluent Cloud集成支持从您的托管Kafka主题自动同步自定义事件到OneSignal。这让您能够基于通过Confluent Cloud流平台流动的实时用户行为数据触发自动化旅程和个性化消息活动。要求
- 访问自定义事件(目前处于测试阶段)
- 升级账户计划(免费应用不可用)。
Confluent Cloud要求
- Confluent Cloud集群,具有活跃的主题
- API凭据,具有对事件主题的读取权限
- Schema Registry(可选,用于结构化事件架构)
- 事件主题,包含具有合适消息格式的行为数据
设置
1
在Confluent Cloud中创建API凭据
在您的Confluent Cloud控制台中为OneSignal生成API凭据:
- 在Confluent Cloud中导航到数据集成 > API密钥
- 点击创建密钥并选择全局访问
- 保存API密钥和API密钥(您在OneSignal中需要这些)
- 从集群设置中记录您的Bootstrap服务器端点
2
配置主题ACL(如果使用细粒度权限)
向OneSignal授予对包含事件数据的特定主题的读取权限:
3
在OneSignal中添加集成
在 OneSignal 中,前往 数据 > 集成,然后点击 添加集成。选择Confluent Cloud并提供:
- Bootstrap服务器:您的Confluent Cloud集群端点
- API密钥:Confluent Cloud API密钥
- API密钥:Confluent Cloud API密钥
- 消费者组:OneSignal的唯一组ID(例如,
onesignal-events
) - Schema Registry URL(可选):如果使用Confluent Schema Registry
4
配置事件主题
指定包含事件数据的Confluent Cloud主题:
- 主题名称:要消费的主题的逗号分隔列表(例如,
user-events,purchase-events
) - 事件格式:JSON、Avro或Protobuf消息格式
- Schema Registry:如果使用结构化架构,请启用
- 事件名称/类型(String)
- 用户标识符(String)
- 事件时间戳(Long/ISO格式)
- 其他事件属性(嵌套JSON)
5
测试连接
点击测试连接以验证OneSignal能够连接到您的Confluent Cloud集群并消费事件消息。
事件数据映射
将您的 映射到 OneSignal 的自定义事件格式:OneSignal 字段 | 描述 | 必需 | |
---|---|---|---|
name | event_name | 事件标识符 | 是 |
external_id | user_id | 用户标识符 | 是 |
timestamp | event_timestamp | 事件发生时间 | 否 |
properties | event_data | 否 |
高级配置
Schema Registry集成
利用Confluent Schema Registry处理结构化事件数据:消费者组管理
OneSignal创建专用的消费者组来跟踪消息偏移量:- 自动提交:成功处理后自动提交偏移量
- 错误处理:记录失败消息并具有重试机制
- 扩展:跨OneSignal消费者实例平衡分区
实时处理
Confluent Cloud实现近实时事件激活:- 低延迟:事件在发布后几秒钟内处理
- 高吞吐量:每秒处理数千个事件
- 故障容错:内置复制和自动故障转移
确保您的Confluent Cloud集群具有足够的吞吐量容量来处理OneSignal的消费率以及您的其他消费者。