Spring Cloud Kafka Streams绑定器偏移指标

Question

有人能举例说明如何使用Spring Cloud Kafka Streams metricSpring吗。云流动粘合剂Kafka。消费者应用程序的偏移量？

编辑：

在花了一些时间进行调查之后，我想补充更多信息。我正在寻找的指标必须向我显示流处理的情况。我的绑定外观如下：

@Input(INCOMING_STREAM)
KStream<String, Update> incomingStream();

@Input(INCOMING_MESSAGE)
MessageChannel incomingMessage();

对我来说很奇怪的是，我可以使用建议的方法看到不同的指标，但仅适用于INCOMING_MESSAGE通道。有没有办法从INCOMING_STREAM中查看指标？




Answer 1

2.0版Spring Cloud Stream中的指标基于千分尺（这是Boot 2.0中使用的默认指标实现）。您可以尝试在应用程序中自动连接计量注册，并在那里检索相关计量。有关一些指针，请参阅此测试。如果不想在应用程序中进行更改，也可以尝试设置spring。云流动绑定。applicationMetrics。目标属性。有关这方面的更多详细信息，请参阅此博客。