我正在使用Prometheus收集我的应用程序的指标，该应用程序是用Java 8（不含Spring）编写的。我使用Kafka Stream读取和Kafka Producer发布。
我想公开应用程序使用的Kafka客户端上的指标，例如计算发送到每个主题的消息，读取的记录数，延迟，发布数等。
我试过使用内置在Collectors中的Prometheus，比如Counter和Histogram。它们工作得很好，但问题是我必须记录每个从Kafka发送或读取数据的方法，这要么是大量的代码重复，要么是对应用程序的巨大重构。
我想知道是否有人遇到过这个问题，并有更好的解决方案。