CheckpointStore.GetCheckpointAsync メソッド

定義

名前空間:

Azure.Messaging.EventHubs.Primitives

アセンブリ:

Azure.Messaging.EventHubs.dll

パッケージ:

Azure.Messaging.EventHubs v5.11.3

ソース:

CheckpointStore.cs

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

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操作を取り消す要求を通知するインスタンス。

戻り値

Task<EventProcessorCheckpoint>

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