個々のコンシューマの使用

カーソルとは、ストリーム内のロケーションを指すポインタです。ロケーションは、パーティション内の特定のオフセットまたは時間です。

メッセージの消費を開始する前に、消費を開始するポイントを指定する必要があります。これには、カーソルを作成します。

個々のコンシューマに対してカーソルを作成する場合、カーソルが使用するストリーム内のパーティションを指定する必要があります。ストリームにメッセージを含むパーティションが複数ある場合は、複数のカーソルを作成してそれらを読み取る必要があります。

カーソルを作成した後、メッセージを取得して消費できます。

メッセージを消費し続けるかぎり、カーソルを再作成する必要はありません。ループの外部にカーソルを作成してメッセージを取得します。

カーソルの作成後、メッセージを取得(読取り)し、メッセージの消費を開始するカーソルを指定します。サービスは、メッセージおよびopc-next-cursorヘッダー値で応答します。戻されたヘッダー値は、次のGetMessagesコールで使用します。返されるカーソルはnullではありませんが、5分後に失効します。5分を超えてメッセージの消費を停止する場合は、カーソルを再作成する必要があります。

複数のコンシューマが同じパーティションから読み取っている場合、それらは同じメッセージを受信します。アプリケーションでこれらのメッセージをどのように処理するかを決定します。

パーティションにそれ以上未読メッセージが存在しない場合、ストリーミングはメッセージの空のリストを返します。

GetMessagesのバッチ・サイズは、ストリームに公開された平均メッセージ・サイズに基づきます。デフォルトでは、サービスはできるだけ多くのメッセージを返します。limitパラメータを使用して最大10,000までの値を指定できますが、ストリームのスループットを超えないように、平均メッセージ・サイズを考慮してください。

オフセットは、パーティション内のメッセージの場所を示します。コンシューマが再開する場合や、障害からリカバリする必要がある場合は、オフセットを使用してストリームからの読取りを再開できます。

個々のコンシューマを使用する場合は、コンシューマ・アプリケーションで処理されたオフセットを管理する必要があります(「オフセットの手動コミット」を参照)。コンシューマは、パーティションごとに到達または停止したオフセットを格納する責任があります。コンシューマが再開したら、処理した最後のメッセージのオフセットを読み取り、AFTER_OFFSETタイプのカーソルを作成して、その取得したオフセットを指定します。処理した最後のメッセージのオフセットを格納するためのガイダンスは提供していません。別のストリーム、マシン上のファイル、オブジェクト・ストレージなどの任意の方法を使用できます。