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

EventProcessorOptions 类

定义

定义向 注册 IEventProcessor 接口 EventHubConsumerGroup时的运行时选项。 这也是从 IEventProcessor EventProcessorHost 对象使用的实例捕获异常的机制。

public class EventProcessorOptions
type EventProcessorOptions = class
Public Class EventProcessorOptions
继承
EventProcessorOptions

构造函数

EventProcessorOptions()

定义向 注册 IEventProcessor 接口 EventHubConsumerGroup时的运行时选项。 这也是从 IEventProcessor EventProcessorHost 对象使用的实例捕获异常的机制。

属性

DefaultOptions

获取默认选项,对于 属性为 MaxBatchSize10,为 ReceiveTimeOut 1 分钟。

EnableReceiverRuntimeMetric

获取或设置一个值,该值指示是否启用接收器的运行时指标。

InitialOffsetProvider

获取或设置一个委托,该委托用于获取给定分区的初始偏移量以创建 EventHubReceiver。 委托是通过传入 PartitionId 调用的,然后用户可以返回开始偏移量作为字符串或开始 UTC 时间以接收消息。 仅当未提供 且首次创建接收方时 Offset ,才使用此选项。 这对应于 CreateReceiverAsync(String, ReceiverOptions)CreateReceiverAsync(String, DateTime, ReceiverOptions) ,具体取决于委托的返回值的类型。

InvokeProcessorAfterReceiveTimeout

如果分区的流中没有更多消息,则启用此选项将导致 ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) 在每次 ReceiveTimeout 之后调用。

MaxBatchSize

获取或设置用户愿意接受的每个接收循环处理的最大事件计数。 此计数按事件中心分区级别计算。

PrefetchCount

获取或设置当前拥有的分区中的任何接收方将主动缓存的事件数。 此属性的默认值为 300。

ReceiveTimeOut

获取或设置事件处理器执行接收操作时用户愿意等待的时间跨度。

事件

ExceptionReceived

每当处理事件时遇到异常时,将触发此事件。 用户可以为此事件注册处理程序以获取异常通知。

适用于