Я бы хотел измерить пропускную способность и время, необходимое для обработки пакета миллионов записей из очереди Kafka. Я написал программу Alpakka для этого, но теперь я хотел бы получить некоторые метрики для этого.
Я пытался использовать sbt-jmh, но безуспешно. Это привело к сбою программы, а также из-за того, что поток akka не завершился без явного выключения, он не выплюнул отчет.
Кто-нибудь пытался использовать sbt-jmh для профилирования системы akka-stream / alpakka? Основные метрики, которые меня интересуют, - это пропускная способность, общее время и общее потребление памяти.