Я использую 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);