PluggableCheckpointStoreEventProcessor<TPartition>.ListOwnershipAsync メソッド

定義

名前空間:

Azure.Messaging.EventHubs.Primitives

アセンブリ:

Azure.Messaging.EventHubs.dll

パッケージ:

Azure.Messaging.EventHubs v5.11.3

ソース:

PluggableCheckpointStoreEventProcessor.cs

特定のイベント ハブとコンシューマー グループのペアリングについて、連携する各イベント プロセッサ インスタンス間のパーティションに対する所有権の割り当ての一覧を要求します。 この方法は、負荷分散中に使用され、プロセッサが他のアクティブなコラボレーターを検出し、それらの間で最適なバランスを取る方法に関する決定を行うことができます。

protected override System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>> ListOwnershipAsync (System.Threading.CancellationToken cancellationToken);

override this.ListOwnershipAsync : System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>

Protected Overrides Function ListOwnershipAsync (cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

パラメーター

cancellationToken

CancellationToken

CancellationToken処理を取り消す要求を通知するインスタンス。 これは、プロセッサのシャットダウン時に発生する可能性が最も高くなります。

戻り値

Task<IEnumerable<EventProcessorPartitionOwnership>>

負荷分散の決定を行うときに考慮する所有権データのセット。