Я собираюсь использовать приемник Apache Flume Avro для отправки сериализованных объектов Avro, но вместо того, чтобы зависеть только от размера пакета, я хотел бы также учитывать прошедшее время между партиями.Это главным образом потому, что я хотел бы использовать оптимизированный размер пакета, но также и для более тихих периодов, когда число ожидаемых событий меньше, чем обычно, без больших задержек между пакетами.Например, размер партии = 1000 или истекшее время = 60000 миллисекунд.
Я не смог найти ничего в документации, относящейся к этому, но задаюсь вопросом, нашел ли кто-нибудь работоспособное решение?
Спасибозаранее.