从 Azure 事件中心收听时出现错误

Question

从 Azure 事件中心收听时出现错误

提供的偏移量 XXXXX 无效。系统中的最后一个偏移量是 XXXXX

分区 1 上的错误：AMQP 对象会话被中止。 分区 0 上的错误：提供的偏移量无效。

Answer 1

我有同样的问题。这是因为共享了一个 EventPosition 类的实例。

var position = EventPosition.FromStart();

var eventProcessorHost = new EventProcessorHost(
    eventHubName,
    consumerGroupName,
    eventHubConnectionString,
    storageConnectionString,
    LeaseContainerName);

host.RegisterEventProcessorFactoryAsync(
    processorFactory,
    new EventProcessorOptions
    {
        // Problem is the following line.
        // In order to fix it replace 'position' with 'EventPosition.FromStart()'
        InitialOffsetProvider = partitionId => position  
    }).Wait();

显然，如果您共享一个位置类的实例，那么 ProcessorHost 对不同的 IEventProcessor(s) 使用相同的对象。由于此对象包含偏移值，因此会导致将相同的偏移量传递给不同的分区 - 显然，如果分区之间的偏移量不同，则会导致问题。