Измерение потребления памяти, пропускной способности и времени, потребляемого потоком Alpakka

Я хотел бы измерить пропускную способность и время, затраченное на обработку пакета миллионов записей из очереди Kafka. Я написал для этого программу Alpakka, но теперь я хотел бы получить некоторые метрики.

Я пытался использовать sbt-jmh но безуспешно. Это привело к сбою программы, а также из-за того, что поток akka не завершается без явного выключения, он не выплевывает отчет.

Кто-нибудь пытался использовать sbt-jmh профилировать систему akka-stream / alpakka? Основные метрики, которые меня интересуют, - это пропускная способность, общее время и общее потребление памяти.

0 ответов

Другие вопросы по тегам