azure - EventProcessorHost 中具有更高纪元的新接收器错误

Question

我正在使用 EventProcessorHost 读取 Eventhub 数据，但出现以下错误。

New receiver with higher epoch of '798393595' is created hence current receiver with epoch '17' is getting disconnected. If you are recreating the receiver, make sure a higher epoch is used. TrackingId:6368f7fc0004165d0001c7bb58238501_G34_B22, SystemTracker:dynmsg-push-evidence:eventhub:push-assignment-execute~28671|dsreporting, Timestamp:11/9/2016 8:21:32 PM

注意 - 我没有使用 EventHubReciever，仅使用 EventProcessorHost 方式从事件中心读取数据。我可以看到它第一次运行并从事件中心读取数据，但之后它总是会抛出如上所述的错误？

无论如何我们可以避免 Epoch 值来读取数据吗？假设我只想使用 EventProcessorHost 来实现此目的。

eventProcessorHost = new EventProcessorHost(eventProcessorHostName,config.EventHubSourceName, string.IsNullOrEmpty(config.EventHubSourceConsumerGroup)? EventHubConsumerGroup.DefaultGroupName:config.EventHubSourceConsumerGroup,
                    config.EventHubSourceConnectionString, config.StorageConnectionString)
                {
                    PartitionManagerOptions = new PartitionManagerOptions()
                    {
                        AcquireInterval = TimeSpan.FromSeconds(10),
                        RenewInterval = TimeSpan.FromSeconds(10),
                        LeaseInterval = TimeSpan.FromSeconds(30)
                    }
                };

                var eventProcessOption = new EventProcessorOptions
                {
                    InvokeProcessorAfterReceiveTimeout = true,
                    MaxBatchSize = 100,
                    PrefetchCount = 100,
                    ReceiveTimeOut = TimeSpan.FromSeconds(30)
                };

                eventProcessOption.ExceptionReceived += EventProcessOption_ExceptionReceived;

                var factory = new EventHubHostFactory(config.FileName, CallbackEventHubData);
               // var eventFactory = new DefaultEventProcessorFactory<factory>();

                await eventProcessorHost.RegisterEventProcessorFactoryAsync(factory, eventProcessOption);

Answer 1

根据经验，此错误是由两个或多个应用程序使用同一消费者组引起的。检查您是否还没有从该使用者组检索数据的应用程序。并清除检查点文件。