Мне интересно, есть ли способ обновить текущее значение Offset, SequenceNumber или EnqueuedTimeUtc, с которого начинает считывать EventHubTrigger.
Я не использую захват Eventhub.Но допустим, что срок хранения сообщения составляет 7 дней, и функция в настоящее время обработала все сообщения.Могу ли я обновить группу потребителей, чтобы она воспроизводила все сообщения (из всех разделов), начиная с любого заданного времени за последние 7 дней?
Можно ли так же быстро переадресовать группу потребителей, которая в данный момент находится в процессе обработки, чтобы не обрабатывать сообщения раньше определенного времени?
Я не вижу ни одного хоста.Опции json или входные привязки для этого.
Возможно ли это только с помощью EventProcessorHost, а не привязки EventHubTrigger?
Вот упрощенная версия функции.
[FunctionName("ProcessEvents")]
public async Task ProcessEvents([EventHubTrigger("%EventHub-Name%", Connection = "EventHub-Connection", ConsumerGroup = "%EventHub-Consumer%")] EventData[] events, ILogger log)
{
var exceptions = new List<Exception>();
foreach (EventData eventData in events)
{
try
{
await DoSomethingWithEvent(eventData);
}
catch (Exception e)
{
exceptions.Add(e);
await DoSomethingWithError(e);
}
}
if (exceptions.Count > 1)
throw new AggregateException(exceptions);
if (exceptions.Count == 1)
throw exceptions.Single();
}
Спасибо!