Показатели смещения связующего в Spring Cloud Kafka Streams - PullRequest
Новая
       48

Показатели смещения связующего в Spring Cloud Kafka Streams

0 голосов
/ 11 октября 2018

Может кто-нибудь привести пример использования метрики Spring Cloud Kafka Streams spring.cloud.stream.binder.kafka.offset для потребительского приложения?

Редактировать:

Я хотел бы добавить больше информации после некотороговремя, затрачиваемое на расследование.Метрики, которые я ищу, должны показать мне ситуацию с моей потоковой обработкой.Мое связывание выглядит следующим образом: 

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

@Input(INCOMING_MESSAGE)
MessageChannel incomingMessage();

И что довольно странно для меня, я вижу разные метрики, используя предложенные подходы, но только для канала INCOMING_MESSAGE.Есть ли способ увидеть метрики из INCOMING_STREAM?

1 Ответ

0 голосов
/ 16 октября 2018

Метрики в Spring Cloud Stream от 2.0 основаны на микрометре (который является реализацией метрик по умолчанию, используемой в Boot 2.0).Вы можете попробовать autowire a MeterRegistry в вашем приложении и получить соответствующие метрики там.См. этот тест для некоторых указателей.Если вы не хотите вносить изменения в свое приложение, вы также можете попробовать установить свойство spring.cloud.stream.bindings.applicationMetrics.destination.Подробнее об этом см. этот блог .

...