Я пытаюсь добавить шаблон в свою систему мониторинга для мониторинга Mirror Maker 2.0
Из документации я знаю, что эти метрики поставляются в формате jmx
# MBean: kafka.connect.mirror:type=MirrorSourceConnector,target=.
([-.w]+),topic=([-.w]+),partition=([0-9]+)
record-count # number of records replicated source -> target
record-age-ms # age of records when they are replicated
record-age-ms-min
record-age-ms-max
record-age-ms-avg
replication-latecny-ms # time it takes records to propagate source->target
replication-latency-ms-min
replication-latency-ms-max
replication-latency-ms-avg
byte-rate # average number of bytes/sec in replicated records
Если я хотел контролировать задержка репликации между кластерами, это должно быть выведено из рекорд-возраста-мс? (ie если этот возраст мс продолжает расти, то задержка продолжает расти?)
Спасибо