你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
EventProcessorOptions 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
定义向 注册 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 |
每当处理事件时遇到异常时,将触发此事件。 用户可以为此事件注册处理程序以获取异常通知。 |