scala - 测量 Alpakka 流的内存消耗、吞吐量和时间

Question

我想测量处理来自 Kafka 队列的数百万条记录的吞吐量和时间。我已经编写了 Alpakka 程序来执行此操作，但现在我想获得一些关于它的指标。

我尝试使用sbt-jmh但不成功。它使程序崩溃了，而且还因为 akka-stream 在没有明确关闭的情况下不会终止，它不会吐出报告。

有没有人尝试使用sbt-jmh分析 akka-stream/alpakka 系统？我感兴趣的主要指标是吞吐量、总耗时和总内存消耗。