EventHubClient.CreateEpochReceiver Método

Definición

Espacio de nombres:

Microsoft.Azure.EventHubs

Ensamblado:

Microsoft.Azure.EventHubs.dll

Paquete:

Microsoft.Azure.EventHubs v4.3.2

Source:

EventHubClient.cs

Cree un receptor eventHub basado en época con dado EventPosition. El receptor se crea para una partición de EventHub específica del grupo de consumidores específico.

Es importante prestar atención a lo siguiente al crear un receptor basado en época:

- Aplicación de propiedad: una vez creado un receptor basado en época, no se puede crear un receptor que no sea de época en el mismo combo consumerGroup-Partition hasta que se cierren todos los receptores del combo.

- Robo de propiedad: si se crea un receptor con mayor valor de época para un combo consumerGroup-Partition, se forzará el cierre de cualquier receptor de época anterior a ese combo.

- Cualquier receptor cerrado debido a la pérdida de propiedad en un combo consumerGroup-Partition obtendrá ReceiverDisconnectedException para todas las operaciones de ese receptor.

public Microsoft.Azure.EventHubs.PartitionReceiver CreateEpochReceiver(string consumerGroupName, string partitionId, Microsoft.Azure.EventHubs.EventPosition eventPosition, long epoch, Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions = default);

member this.CreateEpochReceiver : string * string * Microsoft.Azure.EventHubs.EventPosition * int64 * Microsoft.Azure.EventHubs.ReceiverOptions -> Microsoft.Azure.EventHubs.PartitionReceiver

Public Function CreateEpochReceiver (consumerGroupName As String, partitionId As String, eventPosition As EventPosition, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As PartitionReceiver

Parámetros

consumerGroupName

String

el nombre del grupo de consumidores en el que se debe agrupar este receptor.

partitionId

String

el identificador de partición al que pertenece el receptor. Todos los datos recibidos serán solo de esta partición.

eventPosition

EventPosition

A partir del cual se empiezan EventPosition a recibir mensajes.

epoch

Int64

un identificador único (valor de época) que usa el servicio para aplicar la propiedad de partición o concesión.

receiverOptions

ReceiverOptions

Opciones para un receptor de centro de eventos.

Devoluciones

PartitionReceiver

PartitionReceiver creado

Consulte también

• PartitionReceiver