BlobCheckpointStore.GetCheckpointAsync メソッド

リファレンス

定義

名前空間:: Azure.Messaging.EventHubs.Primitives

アセンブリ:: Azure.Messaging.EventHubs.Processor.dll

パッケージ:: Azure.Messaging.EventHubs.Processor v5.11.3

パッケージ:: Azure.Messaging.EventHubs.Processor v5.12.0-beta.1

ソース:: BlobCheckpointStore.cs

ソース:: BlobCheckpointStore.cs

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

特定のパーティションのチェックポイント情報を要求し、イベントプロセッサがストリーム内の次のイベントからの読み取りを再開できるようにします。

public override System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint> GetCheckpointAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, System.Threading.CancellationToken cancellationToken);

override this.GetCheckpointAsync : string * string * string * string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint>

Public Overrides Function GetCheckpointAsync (fullyQualifiedNamespace As String, eventHubName As String, consumerGroup As String, partitionId As String, cancellationToken As CancellationToken) As Task(Of EventProcessorCheckpoint)

パラメーター

fullyQualifiedNamespace: String

所有権が関連付けられている完全修飾 Event Hubs 名前空間。これは、と似ている {yournamespace}.servicebus.windows.net可能性があります。

eventHubName: String

所有権が関連付けられている特定のイベントハブの名前。その名前を含む Event Hubs 名前空間を基準にしています。

consumerGroup: String

チェックポイントが関連付けられているコンシューマーグループの名前。

partitionId: String

チェックポイントを読み取るパーティションの識別子。

cancellationToken: CancellationToken

CancellationToken操作を取り消す要求を通知するインスタンス。

戻り値

Task<EventProcessorCheckpoint>

EventProcessorCheckpoint要求されたパーティションのチェックポイントが見つかった場合はインスタンス。nullそれ以外の場合は。

適用対象