我一直在尝试为Akka流设置一些仪器.有了它的工作,但是,即使我将所有流量命名为流的一部分,我仍然会在度量标准中得到这样的名称:flow-0-0-unknown-operation
我正在尝试做的一个简单示例:
val myflow = Flow[String].named("myflow").map(println)
Source.via(myflow).to(Sink.ignore).run()
我基本上希望看到为"myflow"创建的Actor的度量标准,并使用正确的名称.
这甚至可能吗？我错过了什么吗？