PluggableCheckpointStoreEventProcessor<TPartition>.ListOwnershipAsync Methode

  • Referenz

Definition

Namespace:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.dll
Paket:
Azure.Messaging.EventHubs v5.11.3
Paket:
Azure.Messaging.EventHubs v5.12.0-beta.1
Quelle:
PluggableCheckpointStoreEventProcessor.cs
Quelle:
PluggableCheckpointStoreEventProcessor.cs

Fordert eine Liste der Besitzzuweisungen für Partitionen zwischen den einzelnen kooperierenden Ereignisprozessorinstanzen für eine bestimmte Event Hub- und Consumergruppenpaarung an. Diese Methode wird während des Lastenausgleichs verwendet, um es dem Prozessor zu ermöglichen, andere aktive Mitarbeiter zu ermitteln und Entscheidungen darüber zu treffen, wie die Arbeit zwischen ihnen am besten ausgewogen ist.

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))

Parameter

cancellationToken
CancellationToken

Ein CancellationToken instance, um die Anforderung zum Abbrechen der Verarbeitung zu signalisieren. Dies tritt am wahrscheinlichsten auf, wenn der Prozessor heruntergefahren wird.

Gibt zurück

Task<IEnumerable<EventProcessorPartitionOwnership>>

Der Satz von Besitzdaten, die bei Lastenausgleichsentscheidungen berücksichtigt werden sollen.

Gilt für: