我一直在尝试为Akka流设置一些仪器.有了它的工作,但是,即使我将所有流量命名为流的一部分,我仍然会在度量标准中得到这样的名称:flow-0-0-unknown-operation
我正在尝试做的一个简单示例:
val myflow = Flow[String].named("myflow").map(println)
Source.via(myflow).to(Sink.ignore).run()
我基本上希望看到为"myflow"创建的Actor的度量标准,并使用正确的名称.
这甚至可能吗？我错过了什么吗？
我不小心从Kamon Monitoring工具中遇到了Striped64.java类.在第95行,我发现了这个评论:
JVM intrinsics note: It would be possible to use a release-only
form of CAS here, if it were provided.
虽然我理解CAS是什么,但我无法找出CAS的唯一形式.有人可以对此有所了解吗？
我尝试将 kamon-prometheus 与 akka 流项目集成，但在http://localhost:9095/它加载了一个空页面。在控制台中，我可以看到度量信息在http://localhost:9095/可用的消息。当我尝试使用 akka quickstart 项目时，它运行良好。
akka 流是否支持 kamon？