EventHubClient.CreateEpochReceiver Método

  • Referência

Definição

Namespace:
Microsoft.Azure.EventHubs
Assembly:
Microsoft.Azure.EventHubs.dll
Pacote:
Microsoft.Azure.EventHubs v4.3.2
Origem:
EventHubClient.cs

Crie um receptor eventhub baseado em época com determinado EventPosition. O receptor é criado para uma partição específica do EventHub do grupo de consumidores específico.

É importante prestar atenção ao seguinte ao criar o receptor baseado em época:

- Imposição de propriedade: depois de criar um receptor baseado em época, você não poderá criar um receptor não de época para a mesma combinação consumerGroup-Partition até que todos os receptores para a combinação sejam fechados.

- Roubo de propriedade: se um receptor com valor de época mais alto for criado para uma combinação consumerGroup-Partition, qualquer receptor de época mais antigo para essa combinação será forçado a fechar.

- Qualquer receptor fechado devido à perda de propriedade de uma combinação consumerGroup-Partition obterá ReceiverDisconnectedException para todas as operações desse 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

o nome do grupo de consumidores em que esse receptor deve ser agrupado.

partitionId
String

a ID de partição à qual o receptor pertence. Todos os dados recebidos serão somente dessa partição.

eventPosition
EventPosition

A inicialização EventPosition na qual começar a receber mensagens.

epoch
Int64

um identificador exclusivo (valor de época) que o serviço usa para impor a propriedade de partição/concessão.

receiverOptions
ReceiverOptions

Opções para um receptor do hub de eventos.

Retornos

PartitionReceiver

O PartitionReceiver criado

Aplica-se a

Confira também