翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# チャネルの作成
<a name="msk-data-delivery-s3-create"></a>

## AWS マネジメントコンソールの使用
<a name="msk-data-delivery-s3-create-console"></a>

1. [https://console.aws.amazon.com/msk/home?region=us-east-1\#/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/) で Amazon MSK コンソールを開きます。

1. ナビゲーションペインで **[Clusters]** (クラスター) を選択します。

1. Express ブローカーで Amazon MSK プロビジョンドクラスターの名前を選択します。

1. Channel ****タブを選択し、Create **Channel **を選択します。

1. **ソース設定**ステップ:
   + **チャネル名:** 作成するチャネルの名前を入力します。
   + **トピック:** 既存のトピックを選択します。まだ存在しない場合は、新しいトピックを作成します。

1. **送信先設定**ステップに進みます。

1. **送信先タイプ**で、**汎用 S3 へのデータ配信**を選択します。
   + **レコード形式** (JSON、バイト配列、または文字列) を選択します。
   + **送信先設定**:
     + **現在のアカウント**または**クロスアカウント**を選択します。**クロスアカウント**を選択した場合は、追加の**アカウント ID** の入力が必要になる場合があります。
     + 配信バケットの S3 バケット URI を選択または入力します。
     + オプションの S3 バケットプレフィックスと**出力キーテンプレート**を入力します。
     + **ストレージクラス**と**圧縮タイプ** (NONE、GZIP、または ZSTD) を選択します。
   + **データの鮮度** (5～15 分) を設定します。

1. **追加設定**ステップに進みます。

1. **暗号化設定**で、オプションでカスタマーマネージドキーを選択して暗号化設定をカスタマイズします。

1. **サービスアクセス**で、必要なアクセス許可を持つ IAM ロールを選択または作成します。

1. **デッドレターキュー**で、処理不可能なレコードの S3 バケット URI を指定します。必要に応じて、エラー出力プレフィックスを入力します。

1. (オプション) **ログ配信**で、Amazon CloudWatch ロググループ、Amazon S3 バケット、または Amazon Data Firehose ストリームを選択して、モニタリングとトラブルシューティングのためにログを送信します。

1. (オプション) タグを追加します。

1. **レビュー**ステップに進みます。

1. **チャネルの作成**を確認して選択します。

チャネルは**作成**状態になり、配信パイプラインが完全にプロビジョニングされると**アクティブ**に移行します。

## CLI AWS の使用
<a name="msk-data-delivery-s3-create-cli"></a>

ソーストピックは `TopicConfigurationList` (正確に 1 つのトピック) で設定されます。送信先は `IcebergDestinationConfiguration`または `S3DestinationConfiguration` (相互排他的) で設定され、各送信先設定には独自の `ServiceExecutionRoleArn`、 `DataFreshnessInSeconds` (300～900、デフォルト 600)、および が含まれます`DeadLetterQueueS3`。

Amazon S3 汎用バケットの送信先を持つチャネルを作成するには、次のコマンドを使用します。

```
aws kafka create-channel \
    --cluster-arn "arn:aws:kafka:us-east-1:123456789012:cluster/my-express-cluster/abc123" \
    --channel-name "orders-s3-channel" \
    --topic-configuration-list '[
        {
            "TopicArn": "arn:aws:kafka:us-east-1:123456789012:topic/my-express-cluster/abc123/orders-topic",
            "RecordConverter": { "ValueConverter": "JSON" }
        }
    ]' \
    --s3-destination-configuration '{
        "ServiceExecutionRoleArn": "arn:aws:iam::123456789012:role/MSKChannelRole",
        "DataFreshnessInSeconds": 300,
        "DeadLetterQueueS3": {
            "BucketArn": "arn:aws:s3:::my-dlq-bucket",
            "ErrorOutputPrefix": "dlq/"
        },
        "Storage": {
            "BucketArn": "arn:aws:s3:::my-delivery-bucket",
            "OutputPrefix": "expresslink/",
            "OutputKeyTemplate": "!{channel-id}/!{topic-name}/year=!{yyyy}/month=!{MM}/day=!{dd}/hour=!{HH}/!{topic-name}+!{partition-id}+!{kafka-offset}",
            "StorageClass": "STANDARD",
            "CompressionType": "GZIP"
        }
    }'
```

Amazon S3 汎用バケットの場合、 は `JSON`、`BYTE_ARRAY`、または `RecordConverter.ValueConverter`です `STRING` (スキーマレジストリは必要ありません）。では`Storage`、 `CompressionType` は `NONE`、`GZIP`、または で`ZSTD`、 `StorageClass`は `STANDARD`、`INTELLIGENT_TIERING`、または です`GLACIER_IR`。

レスポンスは両方の送信先で同じです。

```
{
    "ChannelArn": "arn:aws:kafka:us-east-1:123456789012:channel/my-express-cluster/abc123/orders-s3-channel",
    "ClusterOperationArn": "arn:aws:kafka:us-east-1:123456789012:cluster-operation/my-express-cluster/abc123/..."
}
```

**注記**  
を使用して`ClusterOperationArn`、非同期オペレーションのステータスとエラーメッセージを追跡します。チャネルは で始まり`CREATING`、`ACTIVE`プロビジョニングが完了すると に移行します。

**API リファレンス** — *Amazon MSK API リファレンス*の`CreateChannel`「」を参照してください。