Блог

Я использую триггер концентратора событий с использованием JAVA.

 @FunctionName("XXXX")
public void myfunction( 
@EventHubTrigger(name = "msg",eventHubName = "xxxxx",connection = "xxx",consumerGroup = "xxx")                   List<String> data,final ExecutionContext context) throws Exception {
}
  

Мне нужен способ начать с предыдущего / старого смещения / порядкового номера / даты и времени. Где мы должны указать в функции Azure, чтобы контролировать, с какой временной метки / порядкового номера она должна начинать чтение из концентратора событий?

EventPosition класс определяет положение элемента EventData в разделе концентратора событий. Позиция может быть смещением, порядковым номером или временем постановки в очередь.

Ссылка: класс EventPosition — Azure SDK для Java

Вот несколько примеров кода на Java, а также связанных с EventPosition : EventPosition — Примеры кода Java