Confluent Cloud

개요

OneSignal + Confluent Cloud 통합을 사용하면 관리형 Kafka 토픽에서 OneSignal로 사용자 지정 이벤트를 자동으로 동기화할 수 있습니다. 이를 통해 Confluent Cloud 스트리밍 플랫폼을 통해 흐르는 실시간 사용자 행동 데이터를 기반으로 자동화된 Journeys 및 개인화된 메시징 캠페인을 트리거할 수 있습니다.

요구 사항

Access to Event Streams for outbound message events (Plan limitations and overages apply)
Access to Custom Events for inbound event syncing (Plan limitations and overages apply)
Updated Account Plan (not available on free apps)

활성 토픽이 있는 Confluent Cloud 클러스터
이벤트 토픽에 대한 읽기 액세스 권한이 있는 API 자격 증명
스키마 레지스트리 (구조화된 이벤트 스키마용 선택 사항)
적절한 메시지 형식으로 행동 데이터를 포함하는 이벤트 토픽

설정

Confluent Cloud에서 API 자격 증명 만들기

Confluent Cloud 콘솔에서 OneSignal용 API 자격 증명을 생성하세요:

Confluent Cloud에서 Data Integration > API Keys로 이동하세요
Create key를 클릭하고 Global access를 선택하세요
API Key 및 API Secret을 저장하세요(OneSignal에 필요함)
클러스터 설정에서 Bootstrap servers 엔드포인트를 기록하세요

토픽 ACL 구성 (세분화된 권한 사용 시)

이벤트 데이터를 포함하는 특정 토픽에 대한 OneSignal 읽기 액세스 권한을 부여하세요:

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>

OneSignal에서 통합 추가

OneSignal에서 Data > Integrations으로 이동하여 Add Integration을 클릭합니다.Confluent Cloud를 선택하고 다음을 제공하세요:

Bootstrap Servers: Confluent Cloud 클러스터 엔드포인트
API Key: Confluent Cloud API 키
API Secret: Confluent Cloud API 시크릿
Consumer Group: OneSignal용 고유한 그룹 ID(예: onesignal-events)
Schema Registry URL (선택 사항): Confluent Schema Registry를 사용하는 경우

이벤트 토픽 구성

이벤트 데이터를 포함하는 Confluent Cloud 토픽을 지정하세요:

Topic Names: 소비할 토픽의 쉼표로 구분된 목록(예: user-events,purchase-events)
Event Format: JSON, Avro 또는 Protobuf 메시지 형식
Schema Registry: 구조화된 스키마를 사용하는 경우 활성화

이벤트 메시지에는 다음이 포함되어야 합니다:

이벤트 이름/유형 (String)
사용자 식별자 (String)
이벤트 타임스탬프 (Long/ISO 형식)
추가 이벤트 속성 (중첩된 JSON)

연결 테스트

Test Connection을 클릭하여 OneSignal이 Confluent Cloud 클러스터에 연결하고 이벤트 메시지를 소비할 수 있는지 확인하세요.

이벤트 데이터 매핑

를 OneSignal의 사용자 지정 이벤트 형식에 매핑합니다:

OneSignal 필드	설명	필수
`name`	`event_name`	이벤트 식별자	Yes
`external_id`	`user_id`	사용자 식별자	Yes
`timestamp`	`event_timestamp`	이벤트가 발생한 시간	No
`properties`	`event_data`	No

Sync Key는 동기화 중 각 행의 고유 식별자로 지정하는 열입니다. OneSignal은 이를 사용하여 행이 이미 처리되었는지 감지하므로, 데이터를 다시 동기화해도 중복 이벤트가 생성되지 않습니다. 행마다 고유한 텍스트 값을 가진 열을 선택하세요. 불리언 값이나 여러 행에서 반복되는 값은 사용하지 마세요.

고급 구성

스키마 레지스트리 통합

구조화된 이벤트 데이터를 위해 Confluent Schema Registry를 활용하세요:

{
  "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"
    }
  }
}

Consumer Group 관리

OneSignal은 메시지 오프셋을 추적하기 위해 전용 컨슈머 그룹을 만듭니다:

자동 커밋: 성공적인 처리 후 오프셋이 자동으로 커밋됨
오류 처리: 재시도 메커니즘으로 실패한 메시지가 기록됨
확장: OneSignal 컨슈머 인스턴스 전체에서 파티션 균형 조정

실시간 처리

Confluent Cloud는 거의 실시간 이벤트 활성화를 가능하게 합니다:

낮은 지연 시간: 게시된 후 몇 초 내에 이벤트가 처리됨
높은 처리량: 초당 수천 개의 이벤트 처리
장애 허용: 내장된 복제 및 자동 장애 조치

Confluent Cloud 클러스터에 다른 컨슈머와 함께 OneSignal의 소비 속도를 처리할 수 있는 충분한 처리량 용량이 있는지 확인하세요.

FAQ

OneSignal이 Confluent Cloud에서 이벤트를 얼마나 자주 소비하나요?

OneSignal은 토픽에 도착하는 즉시 이벤트를 실시간으로 소비하며 최소 지연 시간(일반적으로 5초 미만)으로 처리합니다.

여러 토픽에서 동시에 소비할 수 있나요?

예, OneSignal은 여러 토픽에서 병렬로 소비할 수 있습니다. 구성에서 토픽 이름을 쉼표로 구분된 목록으로 지정하세요.

OneSignal이 Confluent Cloud에 연결할 수 없으면 어떻게 되나요?

OneSignal은 지수 백오프로 연결을 재시도합니다. 연결이 복원되면 이벤트 소비가 자동으로 재개됩니다.

시작하기 & 설정

메시지 채널

Journeys

오디언스 & 사용자 지정 이벤트

분석 & 통합

개인 정보 보호 & 보안

Confluent Cloud

개요

요구 사항

Confluent Cloud

설정

이벤트 데이터 매핑

고급 구성

스키마 레지스트리 통합

Consumer Group 관리

실시간 처리

FAQ

OneSignal이 Confluent Cloud에서 이벤트를 얼마나 자주 소비하나요?

여러 토픽에서 동시에 소비할 수 있나요?

OneSignal이 Confluent Cloud에 연결할 수 없으면 어떻게 되나요?

​개요

​요구 사항

​Confluent Cloud

​설정

​이벤트 데이터 매핑

​고급 구성

​스키마 레지스트리 통합

​Consumer Group 관리

​실시간 처리

​FAQ

​OneSignal이 Confluent Cloud에서 이벤트를 얼마나 자주 소비하나요?

​여러 토픽에서 동시에 소비할 수 있나요?

​OneSignal이 Confluent Cloud에 연결할 수 없으면 어떻게 되나요?

개요

요구 사항

Confluent Cloud

설정

이벤트 데이터 매핑

고급 구성

스키마 레지스트리 통합

Consumer Group 관리

실시간 처리

FAQ

OneSignal이 Confluent Cloud에서 이벤트를 얼마나 자주 소비하나요?

여러 토픽에서 동시에 소비할 수 있나요?

OneSignal이 Confluent Cloud에 연결할 수 없으면 어떻게 되나요?