> ## 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

> Confluent CloudからOneSignalにカスタムイベントを同期して、リアルタイムのユーザー行動に基づいた自動化されたJourneysとパーソナライズされたメッセージングキャンペーンをトリガーします。

export const PLATFORM_0 = "Confluent Cloud"

export const DATA_TYPE_0 = undefined

export const COLUMN_HEADER_0 = undefined

export const PROPERTIES_DESCRIPTION_0 = undefined

## 概要

OneSignal + Confluent Cloud統合により、マネージドKafkaトピックからOneSignalへのカスタムイベントの自動同期が可能になります。これにより、Confluent Cloudストリーミングプラットフォームを流れるリアルタイムのユーザー行動データに基づいて、自動化されたJourneysとパーソナライズされたメッセージングキャンペーンをトリガーできます。

***

## 要件

* アウトバウンドメッセージイベント用の[Event Streams](/docs/ja/event-streams)へのアクセス（プランの制限と超過料金が適用されます）
* インバウンドイベント同期用の[Custom Events](/docs/ja/custom-events)へのアクセス（プランの制限と超過料金が適用されます）
* [更新されたアカウントプラン](https://onesignal.com/pricing)（無料アプリでは利用できません）

### Confluent Cloud

* アクティブなトピックを持つ**Confluent Cloudクラスター**
* イベントトピックへの読み取りアクセス権を持つ**API認証情報**
* **Schema Registry**（オプション、構造化されたイベントスキーマ用）
* 適切なメッセージフォーマットを持つ行動データを含む**イベントトピック**

***

## セットアップ

<Steps>
  <Step title="Confluent CloudでAPI認証情報を作成">
    Confluent CloudコンソールでOneSignal用のAPI認証情報を生成します：

    1. Confluent Cloudで**Data Integration > API Keys**に移動します
    2. **Create key**をクリックし、**Global access**を選択します
    3. **API Key**と**API Secret**を保存します（OneSignalに必要です）
    4. クラスター設定から**Bootstrap servers**エンドポイントをメモします
  </Step>

  <Step title="トピックACLを構成（詳細な権限を使用する場合）">
    イベントデータを含む特定のトピックへの読み取りアクセス権をOneSignalに付与します：

    ```bash theme={null}
    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>
    ```
  </Step>

  <Step title="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を使用する場合
  </Step>

  <Step title="イベントトピックを構成">
    イベントデータを含むConfluent Cloudトピックを指定します：

    * **Topic Names**：消費するトピックのカンマ区切りリスト（例：`user-events,purchase-events`）
    * **Event Format**：JSON、Avro、またはProtobufメッセージフォーマット
    * **Schema Registry**：構造化されたスキーマを使用する場合は有効にします

    イベントメッセージには次が含まれている必要があります：

    * イベント名/タイプ（String）
    * ユーザー識別子（String）
    * イベントタイムスタンプ（Long/ISO形式）
    * 追加のイベントプロパティ（ネストされたJSON）
  </Step>

  <Step title="接続をテスト">
    **Test Connection**をクリックして、OneSignalがConfluent Cloudクラスターに接続し、イベントメッセージを消費できることを確認します。
  </Step>
</Steps>

***

### イベントデータマッピング

{PLATFORM_0} {DATA_TYPE_0}をOneSignalのカスタムイベント形式にマッピングします：

| OneSignalフィールド | {COLUMN_HEADER_0} | 説明                         | 必須  |
| -------------- | ----------------- | -------------------------- | --- |
| `name`         | `event_name`      | イベント識別子                    | はい  |
| `external_id`  | `user_id`         | ユーザー識別子                    | はい  |
| `timestamp`    | `event_timestamp` | イベントが発生した時刻                | いいえ |
| `properties`   | `event_data`      | {PROPERTIES_DESCRIPTION_0} | いいえ |

***

## 高度な構成

### Schema Registry統合

構造化されたイベントデータにConfluent Schema Registryを活用します：

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

### Consumer Group管理

OneSignalは、メッセージオフセットを追跡するための専用のConsumer Groupを作成します：

* **自動コミット**：正常に処理された後、オフセットが自動的にコミットされます
* **エラー処理**：失敗したメッセージは再試行メカニズムでログに記録されます
* **スケーリング**：OneSignal Consumerインスタンス間でパーティションがバランスされます

### リアルタイム処理

Confluent Cloudは、ほぼリアルタイムのイベントアクティベーションを可能にします：

* **低レイテンシ**：公開されてから数秒以内にイベントが処理されます
* **高スループット**：1秒あたり数千のイベントを処理します
* **フォールトトレランス**：組み込みのレプリケーションと自動フェイルオーバー

<Warning>
  Confluent Cloudクラスターが、他のConsumerと並行してOneSignalの消費レートを処理するのに十分なスループット容量を持っていることを確認してください。
</Warning>

***

## FAQ

### OneSignalはConfluent Cloudからイベントをどのくらいの頻度で消費しますか？

OneSignalは、トピックに到着したイベントをリアルタイムで消費し、最小限のレイテンシ（通常5秒未満）で処理します。

### 複数のトピックから同時に消費できますか？

はい、OneSignalは複数のトピックから並行して消費できます。構成でトピック名をカンマ区切りリストとして指定します。

### OneSignalがConfluent Cloudに接続できない場合はどうなりますか？

OneSignalは、指数バックオフで接続を再試行します。接続が復元されると、イベントの消費が自動的に再開されます。