Новый приемник с ошибкой более высокой эпохи в EventProcessorHost

Я использую EventProcessorHost для чтения данных Eventhub, и у меня возникла следующая ошибка.

Создается новый приемник с более высокой эпохой «798393595», поэтому текущий приемник с эпохой «17» отключается. Если вы воссоздаете приемник, убедитесь, что используется более высокая эпоха. TrackingId: 6368f7fc0004165d0001c7bb58238501_G34_B22, SystemTracker: dynmsg-push-очевидность: eventhub: push-assignment-execute ~ 28671 | dsreporting, отметка времени: 9.11.2016 20:21:32

Примечание. Я не использую 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);

person asthanarht    schedule 09.11.2016    source источник
comment
Не могли бы вы опубликовать свой код, пожалуйста?   -  person Thomas    schedule 10.11.2016
comment
отредактировал вопрос с кодом   -  person asthanarht    schedule 10.11.2016
comment
Нет ответа, но вы можете найти помощь здесь   -  person Shaul Behr    schedule 11.12.2016
comment
Вы смогли что-нибудь найти?   -  person Pratik Mehta    schedule 31.07.2017


Ответы (1)


По опыту, эта ошибка возникает из-за использования одной и той же группы потребителей из двух или более приложений. Убедитесь, что у вас еще нет приложения, которое извлекает данные из этой группы потребителей. И очистите файлы контрольных точек.

person Filippo Carraro    schedule 13.05.2020