Я использую функцию «Захват» в Event Hub для помещения объектов в хранилище BLOB-объектов и функцию Azure, запускаемую BLOB-объектами, для их обработки.
Дело в том, что при последующих вызовах поток Avro часто содержит объекты последнего чтения - дублированные объекты.Почти как если бы поток не продвигался или механизм захвата Event Hub не продвигался.