有人能举一个如何使用springcloudkafka的例子吗 spring.cloud.stream.binder.kafka.offset 对于消费者应用程序？
编辑：
经过一段时间的调查，我想补充更多的信息。我要寻找的度量必须显示流处理的情况。接下来是我的绑定：
@Input(INCOMING_STREAM)
KStream<String, Update> incomingStream();
@Input(INCOMING_MESSAGE)
MessageChannel incomingMessage();对我来说很奇怪的是，我可以看到不同的指标使用建议的方法，但只针对 INCOMING_MESSAGE 频道。有什么方法可以从 INCOMING_STREAM ?
1条答案
按热度按时间xdyibdwo1#
springcloudstream2.0中的度量基于micrometer（这是boot2.0中使用的默认度量实现）。你可以试着
autowire一MeterRegistry并在那里检索相关的度量。有关一些指针，请参阅此测试。如果不想在应用程序中进行更改，也可以尝试设置spring.cloud.stream.bindings.applicationMetrics.destination财产。有关这方面的更多详细信息，请参阅此博客。