メッセージの公開

メッセージは、ストリーム内の1つのパーティションに公開されます。ストリームに複数のパーティションがある場合、メッセージを公開するパーティションの決定は、プロデューサがストリーミングAPIとPutMessagesを使用しているか、ストリーミングのKafka互換性を利用しているか、Kafka APIを使用しているかによって異なります。

プロデューサがストリーミングAPIを使用している場合、パーティション化はストリーミング・サービスによってサーバー側で処理されます。プロデューサがKafka APIを使用している場合、パーティション化はKafkaによってクライアント側で処理されます。

メッセージが1MBの制限を超える場合、チャンク化を使用するか、Oracle Cloud Infrastructure Object Storageを使用してメッセージを送信できます。

• チャンク化: 大規模なペイロードを、ストリーミング・サービスで受け入れることができる複数の小さいチャンクに分割できます。チャンクは、通常の(チャンク化されていない)メッセージが格納されるときと同じ方法でサービスに格納されます。唯一の違いは、コンシューマがチャンクを保持し、すべてのチャンクが収集されたときにそれらをメッセージに結合する必要があることです。パーティション内のチャンクは、通常のメッセージと組み合せることができます。

• オブジェクト・ストレージ: 大規模なペイロードはオブジェクト・ストレージに配置され、そのデータへのポインタのみが転送されます。受信者は、このタイプのポインタ・ペイロードを認識し、オブジェクト・ストレージからデータを透過的に読み取ってエンド・ユーザーに提供します。

スロットルを回避してスループットを向上させるために、メッセージをバッチ処理することをお薦めします。メッセージのバッチ・サイズは、1MBを超えないようにしてください。この制限を超えた場合、メッセージの検証は失敗します。

PutMessagesのスロットル・メカニズムは、データ書き込み速度が1パーティション当たり1MB/秒を超えるとアクティブ化されます。1パーティション当たり1MB/秒未満のスループットであるかぎり、ストリームへの書込み数の制限はありません。

詳細は、ストリーミング・リソースの制限を参照してください。