CheckpointStore.GetCheckpointAsync メソッド

定義

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

public abstract System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint> GetCheckpointAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, System.Threading.CancellationToken cancellationToken);
abstract member GetCheckpointAsync : string * string * string * string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint>
Public MustOverride 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操作を取り消す要求を通知するインスタンス。

戻り値

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

適用対象