你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

EventHubClient.CreateEpochReceiver 方法

定义

命名空间:

Microsoft.Azure.EventHubs

程序集:

Microsoft.Azure.EventHubs.dll

包:

Microsoft.Azure.EventHubs v4.3.2

Source:

EventHubClient.cs

使用给定 EventPosition创建基于 Epoch 的 EventHub 接收器。 接收方是为特定使用者组中的特定 EventHub 分区创建的。

创建基于纪元的接收器时，请务必注意以下事项：

- 所有权强制实施：创建基于纪元的接收方后，在关闭组合的所有接收器之前，无法向同一 consumerGroup-Partition 组合创建非纪元接收器。

- 所有权窃取：如果为 consumerGroup-Partition 组合创建了具有较高纪元值的接收器，则将强制关闭该组合的任何较旧的纪元接收器。

- 由于对 consumerGroup-Partition 组合失去所有权而关闭的任何接收方都将从该接收方获取所有操作的 ReceiverDisconnectedException。

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

参数

consumerGroupName

String

此接收方应分组到的使用者组名称。

partitionId

String

接收方所属的分区 ID。 接收的所有数据将仅来自此分区。

eventPosition

EventPosition

EventPosition开始接收消息的起始值。

epoch

Int64

一个唯一标识符 (服务用来强制实施分区/租用所有权) 的纪元值。

receiverOptions

ReceiverOptions

事件中心接收器的选项。

返回

PartitionReceiver

创建的 PartitionReceiver

另请参阅

• PartitionReceiver