Шаблон мониторинга#

MirrorMaker kafka.connect JMX v1.0#

Макросы#

Имя	Значение	Описание
`{$CORAX.DISCOVERY.INTERVAL}`	`30m`	Интервал для правил обнаружения
`{$CORAX.DISCOVERY.LOST_RESOURCES_PERIOD}`	`30d`	Время, через которое удаляется необнаруживаемый элемент данных
`{$CORAX.ITEM.DELAY}`	`1m`	Интервал опроса элемента данных
`{$CORAX.ITEM.HISTORY}`	`2w`	Время хранения истории элемента данных
`{$CORAX.ITEM.TRENDS}`	`30d`	Время хранения динамики изменений элемента данных
`{$CORAX.TUZ_JMX.PASSWORD}`	`mypassword`	Пароль для подключения по JMX
`{$CORAX.TUZ_JMX.USERNAME}`	`myuser`	Пользователь для подключения по JMX

Правила обнаружения#

Правило connect-coordinator-metrics#

Ключ: jmx.get[beans, "kafka.connect:type=connect-coordinator-metrics,client-id=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID} - assigned-connectors`	`jmx["{#JMXOBJ}",assigned-connectors]`	Количество экземпляров коннектора, назначенных в данный момент текущему процессу-воркеру	`Numeric (unsigned)`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - assigned-tasks`	`jmx["{#JMXOBJ}",assigned-tasks]`	Количество задач, назначенных в данный момент данному воркеру	`Numeric (unsigned)`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-rebalance-rate-per-hour`	`jmx["{#JMXOBJ}",failed-rebalance-rate-per-hour]`	Количество неудачных событий перебалансировки в час	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-rebalance-total`	`jmx["{#JMXOBJ}",failed-rebalance-total]`	Общее количество неудачных событий перебалансировки	`Numeric (unsigned)`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - heartbeat-rate`	`jmx["{#JMXOBJ}",heartbeat-rate]`	Количество запросов `heartbeat` в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - heartbeat-response-time-max`	`jmx["{#JMXOBJ}",heartbeat-response-time-max]`	Максимальное время, затрачиваемое на получение ответа на запрос `heartbeat`	`Numeric (unsigned)`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - heartbeat-total`	`jmx["{#JMXOBJ}",heartbeat-total]`	Общее количество запросов `heartbeat`	`Numeric (unsigned)`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-rate`	`jmx["{#JMXOBJ}",join-rate]`	Количество групповых соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-time-avg`	`jmx["{#JMXOBJ}",join-time-avg]`	Среднее время, затрачиваемое на переподключение группы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-time-max`	`jmx["{#JMXOBJ}",join-time-max]`	Максимальное время, необходимое для переподключения группы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-total`	`jmx["{#JMXOBJ}",join-total]`	Общее количество присоединений к группе	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - last-heartbeat-seconds-ago`	`jmx["{#JMXOBJ}",last-heartbeat-seconds-ago]`	Количество секунд, прошедших с момента отправки последнего сигнала координатора	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - last-rebalance-seconds-ago`	`jmx["{#JMXOBJ}",last-rebalance-seconds-ago]`	Количество секунд, прошедших с момента последнего успешного события ребалансировки	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-latency-avg`	`jmx["{#JMXOBJ}",rebalance-latency-avg]`	Среднее время, затрачиваемое группой на успешную ребалансировку, которое может состоять из нескольких неудачных повторных попыток, пока она не завершится успешно	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-latency-max`	`jmx["{#JMXOBJ}",rebalance-latency-max]`	Максимальное время, затрачиваемое группой на успешное восстановление баланса, которое может состоять из нескольких неудачных повторных попыток, пока все не завершится успешно	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-latency-total`	`jmx["{#JMXOBJ}",rebalance-latency-total]`	Общее количество миллисекунд, затраченных данным консьюмером на успешную перебалансировку с момента создания	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-rate-per-hour`	`jmx["{#JMXOBJ}",rebalance-rate-per-hour]`	Количество успешных событий восстановления баланса в час, каждое событие состоит из нескольких неудачных повторных попыток, пока оно не завершится успешно	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-total`	`jmx["{#JMXOBJ}",rebalance-total]`	Общее количество успешных событий ребалансировки, каждое событие состоит из нескольких неудачных повторных попыток, пока оно не завершится успешно	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-rate`	`jmx["{#JMXOBJ}",sync-rate]`	Количество групповых синхронизаций в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-time-avg`	`jmx["{#JMXOBJ}",sync-time-avg]`	Среднее время, затрачиваемое на групповую синхронизацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-time-max`	`jmx["{#JMXOBJ}",sync-time-max]`	Максимальное время, затрачиваемое на групповую синхронизацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-total`	`jmx["{#JMXOBJ}",sync-total]`	Общее количество групповых синхронизаций	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило connect-metrics#

Ключ: jmx.get[beans,"kafka.connect:type=connect-metrics,client-id=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID} - connection-close-rate`	`jmx["{#JMXOBJ}","connection-close-rate"]`	Количество закрытых подключений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-close-total`	`jmx["{#JMXOBJ}","connection-close-total"]`	Общее количество закрытых подключений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-count`	`jmx["{#JMXOBJ}","connection-count"]`	Текущее количество активных подключений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-creation-rate`	`jmx["{#JMXOBJ}","connection-creation-rate"]`	Количество новых установленных подключений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-creation-total`	`jmx["{#JMXOBJ}","connection-creation-total"]`	Общее количество новых установленных подключений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-authentication-rate`	`jmx["{#JMXOBJ}","failed-authentication-rate"]`	Количество подключений с ошибкой аутентификации в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-authentication-total`	`jmx["{#JMXOBJ}","failed-authentication-total"]`	Общее количество подключений с ошибкой аутентификации	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-reauthentication-rate`	`jmx["{#JMXOBJ}","failed-reauthentication-rate"]`	Количество неудачных повторных аутентификаций подключений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-reauthentication-total`	`jmx["{#JMXOBJ}","failed-reauthentication-total"]`	Общее количество неудачных повторных аутентификаций подключений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - incoming-byte-rate`	`jmx["{#JMXOBJ}","incoming-byte-rate"]`	Количество байт, считанных со всех сокетов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - incoming-byte-total`	`jmx["{#JMXOBJ}","incoming-byte-total"]`	Общее количество байт, прочитанных со всех сокетов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-ratio`	`jmx["{#JMXOBJ}","io-ratio"]`	Доля времени, которое поток ввода-вывода потратил на выполнение операций ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-time-ns-avg`	`jmx["{#JMXOBJ}","io-time-ns-avg"]`	Средняя продолжительность операции ввода-вывода за один вызов select в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-time-ns-total`	`jmx["{#JMXOBJ}","io-time-ns-total"]`	Общее время, которое поток ввода-вывода потратил на выполнение операций ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-ratio`	`jmx["{#JMXOBJ}","io-wait-ratio"]`	Доля времени, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-time-ns-avg`	`jmx["{#JMXOBJ}","io-wait-time-ns-avg"]`	Средняя продолжительность времени, которое поток ввода-вывода провел в ожидании готовности сокета для чтения или записи в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-time-ns-total`	`jmx["{#JMXOBJ}","io-wait-time-ns-total"]`	Общее время, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-waittime-total`	`jmx["{#JMXOBJ}","io-waittime-total"]`	Устаревшее Общее время, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - iotime-total`	`jmx["{#JMXOBJ}","iotime-total"]`	Устаревшее Общее время, которое поток ввода-вывода потратил на выполнение операций ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - network-io-rate`	`jmx["{#JMXOBJ}","network-io-rate"]`	Количество сетевых операций (чтение или запись) на всех соединениях в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - network-io-total`	`jmx["{#JMXOBJ}","network-io-total"]`	Общее количество сетевых операций (чтение или запись) на всех соединениях	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - outgoing-byte-rate`	`jmx["{#JMXOBJ}","outgoing-byte-rate"]`	Количество исходящих байт, отправляемых на все серверы в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - outgoing-byte-total`	`jmx["{#JMXOBJ}","outgoing-byte-total"]`	Общее количество исходящих байт, отправленных на все серверы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - reauthentication-latency-avg`	`jmx["{#JMXOBJ}","reauthentication-latency-avg"]`	Средняя задержка, наблюдаемая из-за повторной аутентификации	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - reauthentication-latency-max`	`jmx["{#JMXOBJ}","reauthentication-latency-max"]`	Максимальная задержка, наблюдаемая из-за повторной аутентификации	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-rate`	`jmx["{#JMXOBJ}","request-rate"]`	Количество отправленных запросов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-size-avg`	`jmx["{#JMXOBJ}","request-size-avg"]`	Средний размер отправленных запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-size-max`	`jmx["{#JMXOBJ}","request-size-max"]`	Максимальный размер любого отправленного запроса	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-total`	`jmx["{#JMXOBJ}","request-total"]`	Общее количество отправленных запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - response-rate`	`jmx["{#JMXOBJ}","response-rate"]`	Количество полученных ответов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - response-total`	`jmx["{#JMXOBJ}","response-total"]`	Общее количество полученных ответов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - select-rate`	`jmx["{#JMXOBJ}","select-rate"]`	Количество раз, когда уровень ввода-вывода проверял наличие новой операции ввода-вывода для выполнения в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - select-total`	`jmx["{#JMXOBJ}","select-total"]`	Общее количество раз, когда уровень ввода-вывода проверял наличие новой операции ввода-вывода для выполнения	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-no-reauth-total`	`jmx["{#JMXOBJ}","successful-authentication-no-reauth-total"]`	Общее количество соединений с успешной аутентификацией, где клиент не поддерживает повторную аутентификацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-rate`	`jmx["{#JMXOBJ}","successful-authentication-rate"]`	Количество соединений с успешной аутентификацией в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-total`	`jmx["{#JMXOBJ}","successful-authentication-total"]`	Общее количество соединений с успешной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-reauthentication-rate`	`jmx["{#JMXOBJ}","successful-reauthentication-rate"]`	Количество успешных повторных аутентификаций соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-reauthentication-total`	`jmx["{#JMXOBJ}","successful-reauthentication-total"]`	Общее количество успешных повторных аутентификаций соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило connect-worker-metrics - main attributes#

Ключ: jmx.get[beans,"kafka.connect:type=connect-worker-metrics"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`connector-count`	`jmx["{#JMXOBJ}","connector-count"]`	Количество коннекторов, запущенных на этом воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`connector-startup-attempts-total`	`jmx["{#JMXOBJ}","connector-startup-attempts-total"]`	Общее количество попыток запуска коннекторов, предпринятых этим воркером	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`connector-startup-failure-percentage`	`jmx["{#JMXOBJ}","connector-startup-failure-percentage"]`	Средний процент неудачных запусков коннекторов этого воркера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`connector-startup-failure-total`	`jmx["{#JMXOBJ}","connector-startup-failure-total"]`	Общее количество неудачных запусков коннекторов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`connector-startup-success-percentage`	`jmx["{#JMXOBJ}","connector-startup-success-percentage"]`	Средний процент успешных запусков коннекторов этого воркера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`connector-startup-success-total`	`jmx["{#JMXOBJ}","connector-startup-success-total"]`	Общее количество успешных запусков коннекторов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`task-count`	`jmx["{#JMXOBJ}","task-count"]`	Количество задач, запущенных на этом воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`task-startup-attempts-total`	`jmx["{#JMXOBJ}","task-startup-attempts-total"]`	Общее количество попыток запуска задач, предпринятых этим воркером	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`task-startup-failure-percentage`	`jmx["{#JMXOBJ}","task-startup-failure-percentage"]`	Средний процент неудачных запусков задач этого воркера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`task-startup-failure-total`	`jmx["{#JMXOBJ}","task-startup-failure-total"]`	Общее количество неудачных запусков задач	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`task-startup-success-percentage`	`jmx["{#JMXOBJ}","task-startup-success-percentage"]`	Средний процент успешных запусков задач этого воркера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`task-startup-success-total`	`jmx["{#JMXOBJ}","task-startup-success-total"]`	Общее количество успешных запусков задач	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило connect-worker-metrics - workers#

Ключ: jmx.get[beans,"kafka.connect:type=connect-worker-metrics,connector=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CONNECTOR} - connector-destroyed-task-count`	`jmx["{#JMXOBJ}","connector-destroyed-task-count"]`	Количество уничтоженных задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR} - connector-failed-task-count`	`jmx["{#JMXOBJ}","connector-failed-task-count"]`	Количество завершившихся с ошибкой задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR} - connector-paused-task-count`	`jmx["{#JMXOBJ}","connector-paused-task-count"]`	Количество приостановленных задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR} - connector-restarting-task-count`	`jmx["{#JMXOBJ}","connector-restarting-task-count"]`	Количество перезапускаемых задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR} - connector-running-task-count`	`jmx["{#JMXOBJ}","connector-running-task-count"]`	Количество выполняющихся задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR} - connector-total-task-count`	`jmx["{#JMXOBJ}","connector-total-task-count"]`	Общее количество задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR} - connector-unassigned-task-count`	`jmx["{#JMXOBJ}","connector-unassigned-task-count"]`	Количество неназначенных задач коннектора на воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило connect-worker-rebalance-metrics#

Ключ: jmx.get[beans,"kafka.connect:type=connect-worker-rebalance-metrics"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`completed-rebalances-total`	`jmx["{#JMXOBJ}","completed-rebalances-total"]`	Общее количество завершенных перебалансировок, выполненных этим воркером	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`connect-protocol`	`jmx["{#JMXOBJ}","connect-protocol"]`	Протокол Connect, используемый этим кластером	`TEXT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`0`
`epoch`	`jmx["{#JMXOBJ}","epoch"]`	Эпоха или номер поколения этого воркера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`leader-name`	`jmx["{#JMXOBJ}","leader-name"]`	Имя лидера группы	`TEXT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`0`
`rebalance-avg-time-ms`	`jmx["{#JMXOBJ}","rebalance-avg-time-ms"]`	Среднее время в миллисекундах, затраченное этим воркером на перебалансировку	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`rebalance-max-time-ms`	`jmx["{#JMXOBJ}","rebalance-max-time-ms"]`	Максимальное время в миллисекундах, затраченное этим воркером на перебалансировку	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`rebalancing`	`jmx["{#JMXOBJ}","rebalancing"]`	Выполняет ли данный воркер перебалансировку в данный момент	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`time-since-last-rebalance-ms`	`jmx["{#JMXOBJ}","time-since-last-rebalance-ms"]`	Время в миллисекундах, прошедшее с момента последней завершенной перебалансировки этим воркером	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило connector-metrics#

Ключ: jmx.get[beans,"kafka.connect:type=connector-metrics,connector=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CONNECTOR} - connector-type`	`jmx["{#JMXOBJ}","connector-type"]`	Тип коннектора. Одно из значений: `source` или `sink`	`TEXT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`0`
`{#CONNECTOR} - status`	`jmx["{#JMXOBJ}","status",connector-metrics]`	Статус коннектора. Одно из значений: `unassigned`, `running`, `paused`, `stopped`, `failed` или `restarting`	`TEXT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`0`

Прототипы триггеров

Имя	Приоритет	Выражение	Описание
`{#CONNECTOR} - в состоянии failed`	`AVERAGE`	`count(/SBT Corax MirrorMaker kafka.connect JMX v1.0/jmx["{#JMXOBJ}","status",connector-metrics],#5,"like","failed")=5`	Коннектор вернул статус `failed` последние пять проверок

Правило connector-task-metrics#

Ключ: jmx.get[beans,"kafka.connect:type=connector-task-metrics,connector=*,task=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CONNECTOR}, task #{#TASK} - batch-size-avg`	`jmx["{#JMXOBJ}","batch-size-avg"]`	Среднее количество записей в пакетах, обработанных этой задачей на данный момент	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - batch-size-max`	`jmx["{#JMXOBJ}","batch-size-max"]`	Количество записей в самом большом пакете, обработанном этой задачей на данный момент	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - offset-commit-avg-time-ms`	`jmx["{#JMXOBJ}","offset-commit-avg-time-ms"]`	Среднее время в миллисекундах, затраченное этой задачей на фиксацию смещений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - offset-commit-failure-percentage`	`jmx["{#JMXOBJ}","offset-commit-failure-percentage"]`	Средний процент неудачных попыток фиксации смещений этой задачей	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - offset-commit-max-time-ms`	`jmx["{#JMXOBJ}","offset-commit-max-time-ms"]`	Максимальное время в миллисекундах, затраченное этой задачей на фиксацию смещений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - offset-commit-success-percentage`	`jmx["{#JMXOBJ}","offset-commit-success-percentage"]`	Средний процент успешных попыток фиксации смещений этой задачей	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - pause-ratio`	`jmx["{#JMXOBJ}","pause-ratio"]`	Доля времени, которую эта задача провела в состоянии паузы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - running-ratio`	`jmx["{#JMXOBJ}","running-ratio"]`	Доля времени, которую эта задача провела в активном состоянии	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - status`	`jmx["{#JMXOBJ}","status",connector-task-metrics]`	Статус задачи коннектора. Одно из значений: `unassigned`, `running`, `paused`, `failed` или `restarting`	`TEXT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`0`

Правило source-task-metrics#

Ключ: jmx.get[beans,"kafka.connect:type=source-task-metrics,connector=*,task=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CONNECTOR}, task #{#TASK} - poll-batch-avg-time-ms`	`jmx["{#JMXOBJ}","poll-batch-avg-time-ms"]`	Среднее время в миллисекундах, затраченное этой задачей на опрос пакета исходных записей	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - poll-batch-max-time-ms`	`jmx["{#JMXOBJ}","poll-batch-max-time-ms"]`	Максимальное время в миллисекундах, затраченное этой задачей на опрос пакета исходных записей	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-active-count`	`jmx["{#JMXOBJ}","source-record-active-count"]`	Количество записей, созданных этой задачей, но еще не полностью записанных в Kafka	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-active-count-avg`	`jmx["{#JMXOBJ}","source-record-active-count-avg"]`	Среднее количество записей, созданных этой задачей, но еще не полностью записанных в Kafka	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-active-count-max`	`jmx["{#JMXOBJ}","source-record-active-count-max"]`	Максимальное количество записей, созданных этой задачей, но еще не полностью записанных в Kafka	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-poll-rate`	`jmx["{#JMXOBJ}","source-record-poll-rate"]`	Среднее количество записей в секунду, извлеченных (до преобразований) этой задачей из указанного Source-коннектора на данном воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-poll-total`	`jmx["{#JMXOBJ}","source-record-poll-total"]`	Общее количество записей, извлеченных (до преобразований) этой задачей из указанного Source-коннектора на данном воркере	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-write-rate`	`jmx["{#JMXOBJ}","source-record-write-rate"]`	Среднее количество записей в секунду, записанных в Kafka этой задачей из указанного Source-коннектора на данном воркере с момента последнего перезапуска. Сюда входят только записи после применения преобразований, исключая отфильтрованные	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - source-record-write-total`	`jmx["{#JMXOBJ}","source-record-write-total"]`	Общее количество записей, записанных в Kafka этой задачей из указанного Source-коннектора на данном воркере с момента последнего перезапуска. Сюда входят только записи после применения преобразований, исключая отфильтрованные	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило task-error-metrics#

Ключ: jmx.get[beans,"kafka.connect:type=task-error-metrics,connector=*,task=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CONNECTOR}, task #{#TASK} - deadletterqueue-produce-failures`	`jmx["{#JMXOBJ}","deadletterqueue-produce-failures"]`	Количество неудачных попыток записи в очередь отбраковки (dead letter queue)	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - deadletterqueue-produce-requests`	`jmx["{#JMXOBJ}","deadletterqueue-produce-requests"]`	Количество попыток записи в очередь отбраковки (dead letter queue)	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - last-error-timestamp`	`jmx["{#JMXOBJ}","last-error-timestamp"]`	Временная метка эпохи, когда задача в последний раз столкнулась с ошибкой	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - total-errors-logged`	`jmx["{#JMXOBJ}","total-errors-logged"]`	Количество ошибок, записанных в журнал	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - total-record-errors`	`jmx["{#JMXOBJ}","total-record-errors"]`	Количество ошибок при обработке записей в этой задаче	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - total-record-failures`	`jmx["{#JMXOBJ}","total-record-failures"]`	Количество сбоев при обработке записей в этой задаче	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - total-records-skipped`	`jmx["{#JMXOBJ}","total-records-skipped"]`	Количество записей, пропущенных из-за ошибок	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CONNECTOR}, task #{#TASK} - total-retries`	`jmx["{#JMXOBJ}","total-retries"]`	Количество повторных попыток выполнения операций	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Corax MirrorMaker kafka.connect.mirror JMX v1.0#

Макросы#

Имя	Значение	Описание
`{$CORAX.DISCOVERY.INTERVAL}`	`30m`	Интервал для правил обнаружения
`{$CORAX.DISCOVERY.LOST_RESOURCES_PERIOD}`	`30d`	Время, через которое удаляется необнаруживаемый элемент данных
`{$CORAX.ITEM.DELAY}`	`1m`	Интервал опроса элемента данных
`{$CORAX.ITEM.HISTORY}`	`2w`	Время хранения истории элемента данных
`{$CORAX.ITEM.TRENDS}`	`30d`	Время хранения динамики изменений элемента данных
`{$CORAX.MIRRORMAKER.JMX_PORT_STATUS.OVERAGE}`	`7030`	JMX порт для проверки
`{$CORAX.TUZ_JMX.PASSWORD}`	`pass`	Пароль для подключения по JMX
`{$CORAX.TUZ_JMX.USERNAME}`	`usr`	Пользователь для подключения по JMX

Правила обнаружения#

Правило kafka-connect-mirror#

Ключ: jmx.get[beans,"kafka.connect.mirror:type=*,target=*,topic=*,partition=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - byte-count`	`jmx["{#JMXOBJ}","byte-count"]`	Количество байт, реплицированных в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - byte-rate`	`jmx["{#JMXOBJ}","byte-rate"]`	Среднее количество реплицируемых байт в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - record-age-ms`	`jmx["{#JMXOBJ}","record-age-ms"]`	Возраст входящих исходных записей при репликации в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - record-age-ms-avg`	`jmx["{#JMXOBJ}","record-age-ms-avg"]`	Средний возраст входящих исходных записей при репликации в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - record-age-ms-max`	`jmx["{#JMXOBJ}","record-age-ms-max"]`	Максимальный возраст входящих исходных записей при репликации в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - record-age-ms-min`	`jmx["{#JMXOBJ}","record-age-ms-min"]`	Минимальный возраст входящих исходных записей при репликации в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - record-count`	`jmx["{#JMXOBJ}","record-count"]`	Количество исходных записей, реплицированных в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - record-rate`	`jmx["{#JMXOBJ}","record-rate"]`	Среднее количество исходных записей, реплицируемых в целевой кластер в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - replication-latency-ms`	`jmx["{#JMXOBJ}","replication-latency-ms"]`	Время, необходимое для репликации записей из исходного в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - replication-latency-ms-avg`	`jmx["{#JMXOBJ}","replication-latency-ms-avg"]`	Среднее время, необходимое для репликации записей из исходного в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - replication-latency-ms-max`	`jmx["{#JMXOBJ}","replication-latency-ms-max"]`	Максимальное время, необходимое для репликации записей из исходного в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#TYPE}_{#TARGET}_{#TOPIC}_{#PARTITION} - replication-latency-ms-min`	`jmx["{#JMXOBJ}","replication-latency-ms-min"]`	Минимальное время, необходимое для репликации записей из исходного в целевой кластер	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Метрики без LLD#

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`JMX port status`	`net.tcp.service[tcp,,{$CORAX.MIRRORMAKER.JMX_PORT_STATUS.OVERAGE}]`	Проверяется доступность tcp порта по ip-адресу zabbix-хоста, указанного в макросе `{$CORAX.MIRRORMAKER.JMXPORTSTATUS.OVERAGE}`	`Numeric (unsigned)`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Триггеры без LLD#

Имя	Приоритет	Выражение	Описание
`Corax MirrorMaker: Service is down`	`AVERAGE`	`sum(/SBT Corax MirrorMaker kafka.connect.mirror JMX v1.0/net.tcp.service[tcp,,{$CORAX.MIRRORMAKER.JMX_PORT_STATUS.OVERAGE}],#5)=0`	Установлена недоступность порта последние пять проверок — возможно MirrorMaker не запущен

Corax MirrorMaker kafka.consumer JMX v1.0#

Макросы#

Имя	Значение	Описание
`{$CORAX.DISCOVERY.INTERVAL}`	`30m`	Интервал для правил обнаружения
`{$CORAX.DISCOVERY.LOST_RESOURCES_PERIOD}`	`30d`	Время, через которое удаляется необнаруживаемый элемент данных
`{$CORAX.ITEM.DELAY}`	`1m`	Интервал опроса элемента данных
`{$CORAX.ITEM.HISTORY}`	`2w`	Время хранения истории элемента данных
`{$CORAX.ITEM.TRENDS}`	`30d`	Время хранения динамики изменений элемента данных
`{$CORAX.MIRRORMAKER.RECORDS_LAG.OVERAGE}`	`0`	Максимально допустимая величина лага для консьюмера MirrorMaker. Значение 0 - нет ограничения
`{$CORAX.TUZ_JMX.PASSWORD}`	`pass`	Пароль для подключения по JMX
`{$CORAX.TUZ_JMX.USERNAME}`	`usr`	Пользователь для подключения по JMX

Правила обнаружения#

Правило consumer-coordinator-metrics#

Ключ: jmx.get[beans,"kafka.consumer:type=consumer-coordinator-metrics,client-id=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID} - assigned-partitions`	`jmx["{#JMXOBJ}","assigned-partitions",consumer-coordinator-metrics]`	Количество разделов, в настоящее время назначенных этому потребителю	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - commit-latency-avg`	`jmx["{#JMXOBJ}","commit-latency-avg",consumer-coordinator-metrics]`	Среднее время выполнения запроса на фиксацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - commit-latency-max`	`jmx["{#JMXOBJ}","commit-latency-max",consumer-coordinator-metrics]`	Максимальное время выполнения запроса на фиксацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - commit-rate`	`jmx["{#JMXOBJ}","commit-rate",consumer-coordinator-metrics]`	Количество запросов на фиксацию в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - commit-total`	`jmx["{#JMXOBJ}","commit-total",consumer-coordinator-metrics]`	Общее количество запросов на фиксацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-rebalance-rate-per-hour`	`jmx["{#JMXOBJ}","failed-rebalance-rate-per-hour",consumer-coordinator-metrics]`	Количество неудачных событий перебалансировки в час	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-rebalance-total`	`jmx["{#JMXOBJ}","failed-rebalance-total",consumer-coordinator-metrics]`	Общее количество неудачных событий перебалансировки	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - heartbeat-rate`	`jmx["{#JMXOBJ}","heartbeat-rate",consumer-coordinator-metrics]`	Количество heartbeat-запросов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - heartbeat-response-time-max`	`jmx["{#JMXOBJ}","heartbeat-response-time-max",consumer-coordinator-metrics]`	Максимальное время получения ответа на heartbeat-запрос	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - heartbeat-total`	`jmx["{#JMXOBJ}","heartbeat-total",consumer-coordinator-metrics]`	Общее количество heartbeat-запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-rate`	`jmx["{#JMXOBJ}","join-rate",consumer-coordinator-metrics]`	Количество присоединений к группе в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-time-avg`	`jmx["{#JMXOBJ}","join-time-avg",consumer-coordinator-metrics]`	Среднее время повторного присоединения к группе	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-time-max`	`jmx["{#JMXOBJ}","join-time-max",consumer-coordinator-metrics]`	Максимальное время повторного присоединения к группе	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - join-total`	`jmx["{#JMXOBJ}","join-total",consumer-coordinator-metrics]`	Общее количество присоединений к группе	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - last-heartbeat-seconds-ago`	`jmx["{#JMXOBJ}","last-heartbeat-seconds-ago",consumer-coordinator-metrics]`	Количество секунд с момента последнего heartbeat-запроса координатору	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - last-rebalance-seconds-ago`	`jmx["{#JMXOBJ}","last-rebalance-seconds-ago",consumer-coordinator-metrics]`	Количество секунд с момента последней успешной перебалансировки	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - partition-assigned-latency-avg`	`jmx["{#JMXOBJ}","partition-assigned-latency-avg",consumer-coordinator-metrics]`	Среднее время обратного вызова слушателя назначения разделов при перебалансировке	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - partition-assigned-latency-max`	`jmx["{#JMXOBJ}","partition-assigned-latency-max",consumer-coordinator-metrics]`	Максимальное время обратного вызова слушателя назначения разделов при перебалансировке	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - partition-lost-latency-avg`	`jmx["{#JMXOBJ}","partition-lost-latency-avg",consumer-coordinator-metrics]`	Среднее время обратного вызова слушателя потери раздела при перебалансировке	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - partition-lost-latency-max`	`jmx["{#JMXOBJ}","partition-lost-latency-max",consumer-coordinator-metrics]`	Максимальное время обратного вызова слушателя потери раздела при перебалансировке	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - partition-revoked-latency-avg`	`jmx["{#JMXOBJ}","partition-revoked-latency-avg",consumer-coordinator-metrics]`	Среднее время обратного вызова слушателя отзыва раздела при перебалансировке	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - partition-revoked-latency-max`	`jmx["{#JMXOBJ}","partition-revoked-latency-max",consumer-coordinator-metrics]`	Максимальное время обратного вызова слушателя отзыва раздела при перебалансировке	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-latency-avg`	`jmx["{#JMXOBJ}","rebalance-latency-avg",consumer-coordinator-metrics]`	Среднее время, необходимое для завершения успешной перебалансировки группой, которая может состоять из нескольких неудачных повторных попыток	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-latency-max`	`jmx["{#JMXOBJ}","rebalance-latency-max",consumer-coordinator-metrics]`	Максимальное время, необходимое для завершения успешной перебалансировки группой, которая может состоять из нескольких неудачных повторных попыток	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-latency-total`	`jmx["{#JMXOBJ}","rebalance-latency-total",consumer-coordinator-metrics]`	Общее количество миллисекунд, которое этот потребитель потратил на успешные перебалансировки с момента создания	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-rate-per-hour`	`jmx["{#JMXOBJ}","rebalance-rate-per-hour",consumer-coordinator-metrics]`	Количество успешных перебалансировок в час, каждая из которых могла состоять из нескольких неудачных повторных попыток	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - rebalance-total`	`jmx["{#JMXOBJ}","rebalance-total",consumer-coordinator-metrics]`	Общее количество успешных перебалансировок, каждая из которых могла состоять из нескольких неудачных повторных попыток	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-rate`	`jmx["{#JMXOBJ}","sync-rate",consumer-coordinator-metrics]`	Количество синхронизаций группы в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-time-avg`	`jmx["{#JMXOBJ}","sync-time-avg",consumer-coordinator-metrics]`	Среднее время выполнения синхронизации группы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-time-max`	`jmx["{#JMXOBJ}","sync-time-max",consumer-coordinator-metrics]`	Максимальное время выполнения синхронизации группы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - sync-total`	`jmx["{#JMXOBJ}","sync-total",consumer-coordinator-metrics]`	Общее количество синхронизаций группы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило consumer-fetch-manager-TOPIC-metrics#

Ключ: jmx.get[beans,"kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*,topic=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID}_{#TOPIC} - bytes-consumed-rate`	`jmx["{#JMXOBJ}","bytes-consumed-rate",topic]`	Среднее количество байт, потребленных в секунду для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - bytes-consumed-total`	`jmx["{#JMXOBJ}","bytes-consumed-total",topic]`	Общее количество байт, потребленных для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - fetch-size-avg`	`jmx["{#JMXOBJ}","fetch-size-avg",topic]`	Среднее количество байт, извлеченных за один запрос для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - fetch-size-max`	`jmx["{#JMXOBJ}","fetch-size-max",topic]`	Максимальное количество байт, извлеченных за один запрос для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - records-consumed-rate`	`jmx["{#JMXOBJ}","records-consumed-rate",topic]`	Среднее количество записей, потребленных в секунду для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - records-consumed-total`	`jmx["{#JMXOBJ}","records-consumed-total",topic]`	Общее количество записей, потребленных для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - records-per-request-avg`	`jmx["{#JMXOBJ}","records-per-request-avg",topic]`	Среднее количество записей в каждом запросе для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило consumer-fetch-manager-PARTITION-metrics#

Ключ: jmx.get[beans,"kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*,topic=*,partition=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - preferred-read-replica`	`jmx["{#JMXOBJ}","preferred-read-replica",partition]`	Текущая реплика для чтения для раздела или -1, если чтение идет с лидера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lag`	`jmx["{#JMXOBJ}","records-lag",partition]`	Текущее отставание (lag) раздела	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lag-avg`	`jmx["{#JMXOBJ}","records-lag-avg",partition]`	Среднее отставание (lag) раздела	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lag-max`	`jmx["{#JMXOBJ}","records-lag-max",partition]`	Максимальное отставание (lag) раздела	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lead`	`jmx["{#JMXOBJ}","records-lead",partition]`	Текущее опережение (lead) раздела	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lead-avg`	`jmx["{#JMXOBJ}","records-lead-avg",partition]`	Среднее опережение (lead) раздела	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lead-min`	`jmx["{#JMXOBJ}","records-lead-min",partition]`	Минимальное опережение (lead) раздела	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Прототипы триггеров

Имя	Приоритет	Выражение	Описание
`{#CLIENTID}_{#TOPIC}_{#PARTITION} - records-lag больше допустимого`	`AVERAGE`	`last(/SBT Corax MirrorMaker kafka.consumer JMX v1.0/jmx["{#JMXOBJ}","records-lag",partition])>{$CORAX.MIRRORMAKER.RECORDS_LAG.OVERAGE} and {$CORAX.MIRRORMAKER.RECORDS_LAG.OVERAGE}>0`	Отставание при чтении топика репликации превысило допустимое значение

Правило consumer-metrics#

Ключ: jmx.get[beans,"kafka.consumer:type=consumer-metrics,client-id=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID} - commit-sync-time-ns-total`	`jmx["{#JMXOBJ}","commit-sync-time-ns-total",consumer-metrics]`	Общее время, которое потребитель потратил на `commitSync`, в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - committed-time-ns-total`	`jmx["{#JMXOBJ}","committed-time-ns-total",consumer-metrics]`	Общее время, которое потребитель потратил на `committed`, в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-close-rate`	`jmx["{#JMXOBJ}","connection-close-rate",consumer-metrics]`	Количество закрытых соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-close-total`	`jmx["{#JMXOBJ}","connection-close-total",consumer-metrics]`	Общее количество закрытых соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-count`	`jmx["{#JMXOBJ}","connection-count",consumer-metrics]`	Текущее количество активных соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-creation-rate`	`jmx["{#JMXOBJ}","connection-creation-rate",consumer-metrics]`	Количество новых соединений, устанавливаемых в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-creation-total`	`jmx["{#JMXOBJ}","connection-creation-total",consumer-metrics]`	Общее количество новых установленных соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-authentication-rate`	`jmx["{#JMXOBJ}","failed-authentication-rate",consumer-metrics]`	Количество соединений с ошибкой аутентификации в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-authentication-total`	`jmx["{#JMXOBJ}","failed-authentication-total",consumer-metrics]`	Общее количество соединений с ошибкой аутентификации	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-reauthentication-rate`	`jmx["{#JMXOBJ}","failed-reauthentication-rate",consumer-metrics]`	Количество неудачных повторных аутентификаций соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-reauthentication-total`	`jmx["{#JMXOBJ}","failed-reauthentication-total",consumer-metrics]`	Общее количество неудачных повторных аутентификаций соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - incoming-byte-rate`	`jmx["{#JMXOBJ}","incoming-byte-rate",consumer-metrics]`	Количество байт, считанных со всех сокетов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - incoming-byte-total`	`jmx["{#JMXOBJ}","incoming-byte-total",consumer-metrics]`	Общее количество байт, считанных со всех сокетов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-ratio`	`jmx["{#JMXOBJ}","io-ratio",consumer-metrics]`	Доля времени, которое поток ввода-вывода тратит на выполнение операций ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-time-ns-avg`	`jmx["{#JMXOBJ}","io-time-ns-avg",consumer-metrics]`	Среднее время выполнения одной операции ввода-вывода (select) в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-time-ns-total`	`jmx["{#JMXOBJ}","io-time-ns-total",consumer-metrics]`	Общее время, потраченное потоком ввода-вывода на выполнение операций I/O	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-ratio`	`jmx["{#JMXOBJ}","io-wait-ratio",consumer-metrics]`	Доля времени, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-time-ns-avg`	`jmx["{#JMXOBJ}","io-wait-time-ns-avg",consumer-metrics]`	Среднее время, которое поток ввода-вывода провел в ожидании готовности сокета к чтению или записи, в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-time-ns-total`	`jmx["{#JMXOBJ}","io-wait-time-ns-total",consumer-metrics]`	Общее время, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-waittime-total`	`jmx["{#JMXOBJ}","io-waittime-total",consumer-metrics]`	Устарело Общее время, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - iotime-total`	`jmx["{#JMXOBJ}","iotime-total",consumer-metrics]`	Устарело Общее время, которое поток ввода-вывода провел за выполнением операций I/O	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - last-poll-seconds-ago`	`jmx["{#JMXOBJ}","last-poll-seconds-ago",consumer-metrics]`	Количество секунд с момента последнего вызова poll()	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - network-io-rate`	`jmx["{#JMXOBJ}","network-io-rate",consumer-metrics]`	Количество сетевых операций (чтение или запись) по всем соединениям в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - network-io-total`	`jmx["{#JMXOBJ}","network-io-total",consumer-metrics]`	Общее количество сетевых операций (чтение или запись) по всем соединениям	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - outgoing-byte-rate`	`jmx["{#JMXOBJ}","outgoing-byte-rate",consumer-metrics]`	Количество исходящих байт, отправляемых на все серверы в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - outgoing-byte-total`	`jmx["{#JMXOBJ}","outgoing-byte-total",consumer-metrics]`	Общее количество исходящих байт, отправленных на все серверы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - poll-idle-ratio-avg`	`jmx["{#JMXOBJ}","poll-idle-ratio-avg",consumer-metrics]`	Средняя доля времени, когда poll() потребителя простаивает, в отличие от обработки записей пользовательским кодом	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - reauthentication-latency-avg`	`jmx["{#JMXOBJ}","reauthentication-latency-avg",consumer-metrics]`	Средняя задержка, вызванная повторной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - reauthentication-latency-max`	`jmx["{#JMXOBJ}","reauthentication-latency-max",consumer-metrics]`	Максимальная задержка, вызванная повторной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-rate`	`jmx["{#JMXOBJ}","request-rate",consumer-metrics]`	Количество отправляемых запросов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-size-avg`	`jmx["{#JMXOBJ}","request-size-avg",consumer-metrics]`	Средний размер отправляемых запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-size-max`	`jmx["{#JMXOBJ}","request-size-max",consumer-metrics]`	Максимальный размер отправленного запроса	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-total`	`jmx["{#JMXOBJ}","request-total",consumer-metrics]`	Общее количество отправленных запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - response-rate`	`jmx["{#JMXOBJ}","response-rate",consumer-metrics]`	Количество полученных ответов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - response-total`	`jmx["{#JMXOBJ}","response-total",consumer-metrics]`	Общее количество полученных ответов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - select-rate`	`jmx["{#JMXOBJ}","select-rate",consumer-metrics]`	Количество проверок слоя I/O на наличие новых операций I/O в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - select-total`	`jmx["{#JMXOBJ}","select-total",consumer-metrics]`	Общее количество проверок слоя I/O на наличие новых операций I/O	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-no-reauth-total`	`jmx["{#JMXOBJ}","successful-authentication-no-reauth-total",consumer-metrics]`	Общее количество соединений с успешной аутентификацией, где клиент не поддерживает повторную аутентификацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-rate`	`jmx["{#JMXOBJ}","successful-authentication-rate",consumer-metrics]`	Количество соединений с успешной аутентификацией в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-total`	`jmx["{#JMXOBJ}","successful-authentication-total",consumer-metrics]`	Общее количество соединений с успешной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-reauthentication-rate`	`jmx["{#JMXOBJ}","successful-reauthentication-rate",consumer-metrics]`	Количество успешных повторных аутентификаций соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-reauthentication-total`	`jmx["{#JMXOBJ}","successful-reauthentication-total",consumer-metrics]`	Общее количество успешных повторных аутентификаций соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - time-between-poll-avg`	`jmx["{#JMXOBJ}","time-between-poll-avg",consumer-metrics]`	Средняя задержка между вызовами poll() в миллисекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - time-between-poll-max`	`jmx["{#JMXOBJ}","time-between-poll-max",consumer-metrics]`	Максимальная задержка между вызовами poll() в миллисекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Corax MirrorMaker kafka.producer JMX v1.0#

Макросы#

Имя	Значение	Описание
`{$CORAX.DISCOVERY.INTERVAL}`	`30m`	Интервал для правил обнаружения
`{$CORAX.DISCOVERY.LOST_RESOURCES_PERIOD}`	`30d`	Время, через которое удаляется необнаруживаемый элемент данных
`{$CORAX.ITEM.DELAY}`	`1m`	Интервал опроса элемента данных
`{$CORAX.ITEM.HISTORY}`	`2w`	Время хранения истории элемента данных
`{$CORAX.ITEM.TRENDS}`	`30d`	Время хранения динамики изменений элемента данных
`{$CORAX.TUZ_JMX.PASSWORD}`	`pass`	Пароль для подключения по JMX
`{$CORAX.TUZ_JMX.USERNAME}`	`usr`	Пользователь для подключения по JMX

Правила обнаружения#

Правило producer-metrics#

Ключ: jmx.get[beans,"kafka.producer:type=producer-metrics,client-id=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID} - batch-size-avg`	`jmx["{#JMXOBJ}","batch-size-avg",producer]`	Среднее количество байт, отправленных на раздел за один запрос	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - batch-size-max`	`jmx["{#JMXOBJ}","batch-size-max",producer]`	Максимальное количество байт, отправленных на раздел за один запрос	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - batch-split-rate`	`jmx["{#JMXOBJ}","batch-split-rate",producer]`	Среднее количество разделений пакета в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - batch-split-total`	`jmx["{#JMXOBJ}","batch-split-total",producer]`	Общее количество разделений пакета	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - buffer-available-bytes`	`jmx["{#JMXOBJ}","buffer-available-bytes",producer]`	Объем доступной (неиспользуемой) буферной памяти, включая нераспределенную и свободную	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - buffer-exhausted-rate`	`jmx["{#JMXOBJ}","buffer-exhausted-rate",producer]`	Среднее количество отправок записей, отброшенных из-за исчерпания буфера, в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - buffer-exhausted-total`	`jmx["{#JMXOBJ}","buffer-exhausted-total",producer]`	Общее количество отправок записей, отброшенных из-за исчерпания буфера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - buffer-total-bytes`	`jmx["{#JMXOBJ}","buffer-total-bytes",producer]`	Максимальный объем буферной памяти, доступный клиенту (используемой или неиспользуемой)	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - bufferpool-wait-ratio`	`jmx["{#JMXOBJ}","bufferpool-wait-ratio",producer]`	Доля времени, в течение которого аппендер ожидает выделения памяти из буфера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - bufferpool-wait-time-ns-total`	`jmx["{#JMXOBJ}","bufferpool-wait-time-ns-total",producer]`	Общее время ожидания аппендера выделения памяти из буфера в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - bufferpool-wait-time-total`	`jmx["{#JMXOBJ}","bufferpool-wait-time-total",producer]`	Устарело Общее время ожидания аппендера выделения памяти из буфера	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - compression-rate-avg`	`jmx["{#JMXOBJ}","compression-rate-avg",producer]`	Средняя степень сжатия пакетов записей, определяемая как отношение размера сжатого пакета к размеру несжатого	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-close-rate`	`jmx["{#JMXOBJ}","connection-close-rate",producer]`	Количество закрытых соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-close-total`	`jmx["{#JMXOBJ}","connection-close-total",producer]`	Общее количество закрытых соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-count`	`jmx["{#JMXOBJ}","connection-count",producer]`	Текущее количество активных соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-creation-rate`	`jmx["{#JMXOBJ}","connection-creation-rate",producer]`	Количество новых соединений, устанавливаемых в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - connection-creation-total`	`jmx["{#JMXOBJ}","connection-creation-total",producer]`	Общее количество установленных новых соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-authentication-rate`	`jmx["{#JMXOBJ}","failed-authentication-rate",producer]`	Количество соединений с неудачной аутентификацией в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-authentication-total`	`jmx["{#JMXOBJ}","failed-authentication-total",producer]`	Общее количество соединений с неудачной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-reauthentication-rate`	`jmx["{#JMXOBJ}","failed-reauthentication-rate",producer]`	Количество неудачных повторных аутентификаций соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - failed-reauthentication-total`	`jmx["{#JMXOBJ}","failed-reauthentication-total",producer]`	Общее количество неудачных повторных аутентификаций соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - flush-time-ns-total`	`jmx["{#JMXOBJ}","flush-time-ns-total",producer]`	Общее время, которое продюсер провел в операции flush в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - incoming-byte-rate`	`jmx["{#JMXOBJ}","incoming-byte-rate",producer]`	Количество байт, прочитанных со всех сокетов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - incoming-byte-total`	`jmx["{#JMXOBJ}","incoming-byte-total",producer]`	Общее количество байт, прочитанных со всех сокетов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-ratio`	`jmx["{#JMXOBJ}","io-ratio",producer]`	Доля времени, которое поток ввода-вывода потратил на операции ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-time-ns-avg`	`jmx["{#JMXOBJ}","io-time-ns-avg",producer]`	Средняя продолжительность операций ввода-вывода на вызов select в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-time-ns-total`	`jmx["{#JMXOBJ}","io-time-ns-total",producer]`	Общее время, которое поток ввода-вывода потратил на операции I/O	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-ratio`	`jmx["{#JMXOBJ}","io-wait-ratio",producer]`	Доля времени, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-time-ns-avg`	`jmx["{#JMXOBJ}","io-wait-time-ns-avg",producer]`	Средняя продолжительность ожидания готовности сокета к чтению/записи в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-wait-time-ns-total`	`jmx["{#JMXOBJ}","io-wait-time-ns-total",producer]`	Общее время ожидания, потраченное потоком ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - io-waittime-total`	`jmx["{#JMXOBJ}","io-waittime-total",producer]`	Устарело Общее время, которое поток ввода-вывода провел в ожидании	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - iotime-total`	`jmx["{#JMXOBJ}","iotime-total",producer]`	Устарело Общее время, которое поток ввода-вывода провел в операциях I/O	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - metadata-age`	`jmx["{#JMXOBJ}","metadata-age",producer]`	Возраст (в секундах) текущих метаданных продюсера, используемых в работе	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - metadata-wait-time-ns-total`	`jmx["{#JMXOBJ}","metadata-wait-time-ns-total",producer]`	Общее время, которое продюсер потратил в ожидании метаданных топика (в наносекундах)	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - network-io-rate`	`jmx["{#JMXOBJ}","network-io-rate",producer]`	Количество сетевых операций (чтение или запись) на всех соединениях в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - network-io-total`	`jmx["{#JMXOBJ}","network-io-total",producer]`	Общее количество сетевых операций (чтение или запись) на всех соединениях	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - outgoing-byte-rate`	`jmx["{#JMXOBJ}","outgoing-byte-rate",producer]`	Количество исходящих байт, отправляемых на все серверы в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - outgoing-byte-total`	`jmx["{#JMXOBJ}","outgoing-byte-total",producer]`	Общее количество исходящих байт, отправленных на все серверы	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - produce-throttle-time-avg`	`jmx["{#JMXOBJ}","produce-throttle-time-avg",producer]`	Среднее время в миллисекундах, на которое брокер ограничивал запрос	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - produce-throttle-time-max`	`jmx["{#JMXOBJ}","produce-throttle-time-max",producer]`	Максимальное время в миллисекундах, на которое брокер ограничивал запрос	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - reauthentication-latency-avg`	`jmx["{#JMXOBJ}","reauthentication-latency-avg",producer]`	Средняя задержка, вызванная повторной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - reauthentication-latency-max`	`jmx["{#JMXOBJ}","reauthentication-latency-max",producer]`	Максимальная задержка, вызванная повторной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-error-rate`	`jmx["{#JMXOBJ}","record-error-rate",producer]`	Среднее количество отправок записей в секунду, завершившихся ошибкой	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-error-total`	`jmx["{#JMXOBJ}","record-error-total",producer]`	Общее количество отправок записей, завершившихся ошибкой	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-queue-time-avg`	`jmx["{#JMXOBJ}","record-queue-time-avg",producer]`	Среднее время (в мс), проведенное пакетами записей в буфере отправки	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-queue-time-max`	`jmx["{#JMXOBJ}","record-queue-time-max",producer]`	Максимальное время (в мс), проведенное пакетами записей в буфере отправки	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-retry-rate`	`jmx["{#JMXOBJ}","record-retry-rate",producer]`	Среднее количество повторных попыток отправки записей в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-retry-total`	`jmx["{#JMXOBJ}","record-retry-total",producer]`	Общее количество повторных попыток отправки записей	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-send-rate`	`jmx["{#JMXOBJ}","record-send-rate",producer]`	Среднее количество отправляемых записей в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-send-total`	`jmx["{#JMXOBJ}","record-send-total",producer]`	Общее количество отправленных записей	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-size-avg`	`jmx["{#JMXOBJ}","record-size-avg",producer]`	Средний размер записи	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - record-size-max`	`jmx["{#JMXOBJ}","record-size-max",producer]`	Максимальный размер записи	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - records-per-request-avg`	`jmx["{#JMXOBJ}","records-per-request-avg",producer]`	Среднее количество записей на один запрос	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-latency-avg`	`jmx["{#JMXOBJ}","request-latency-avg",producer]`	Средняя задержка запроса в миллисекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-latency-max`	`jmx["{#JMXOBJ}","request-latency-max",producer]`	Максимальная задержка запроса в миллисекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-rate`	`jmx["{#JMXOBJ}","request-rate",producer]`	Количество отправленных запросов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-size-avg`	`jmx["{#JMXOBJ}","request-size-avg",producer]`	Средний размер отправленных запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-size-max`	`jmx["{#JMXOBJ}","request-size-max",producer]`	Максимальный размер любого отправленного запроса	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - request-total`	`jmx["{#JMXOBJ}","request-total",producer]`	Общее количество отправленных запросов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - requests-in-flight`	`jmx["{#JMXOBJ}","requests-in-flight",producer]`	Текущее количество находящихся в обработке запросов, ожидающих ответа	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - response-rate`	`jmx["{#JMXOBJ}","response-rate",producer]`	Количество полученных ответов в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - response-total`	`jmx["{#JMXOBJ}","response-total",producer]`	Общее количество полученных ответов	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - select-rate`	`jmx["{#JMXOBJ}","select-rate",producer]`	Количество проверок I/O-слоем на наличие новых операций ввода-вывода в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - select-total`	`jmx["{#JMXOBJ}","select-total",producer]`	Общее количество проверок I/O-слоем на наличие новых операций ввода-вывода	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-no-reauth-total`	`jmx["{#JMXOBJ}","successful-authentication-no-reauth-total",producer]`	Общее количество соединений с успешной аутентификацией, при которых клиент не поддерживает повторную аутентификацию	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-rate`	`jmx["{#JMXOBJ}","successful-authentication-rate",producer]`	Количество соединений с успешной аутентификацией в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-authentication-total`	`jmx["{#JMXOBJ}","successful-authentication-total",producer]`	Общее количество соединений с успешной аутентификацией	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-reauthentication-rate`	`jmx["{#JMXOBJ}","successful-reauthentication-rate",producer]`	Количество успешных повторных аутентификаций соединений в секунду	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - successful-reauthentication-total`	`jmx["{#JMXOBJ}","successful-reauthentication-total",producer]`	Общее количество успешных повторных аутентификаций соединений	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - txn-abort-time-ns-total`	`jmx["{#JMXOBJ}","txn-abort-time-ns-total",producer]`	Общее время, затраченное продюсером на выполнение abortTransaction в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - txn-begin-time-ns-total`	`jmx["{#JMXOBJ}","txn-begin-time-ns-total",producer]`	Общее время, затраченное продюсером на выполнение beginTransaction в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - txn-commit-time-ns-total`	`jmx["{#JMXOBJ}","txn-commit-time-ns-total",producer]`	Общее время, затраченное продюсером на выполнение commitTransaction в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - txn-init-time-ns-total`	`jmx["{#JMXOBJ}","txn-init-time-ns-total",producer]`	Общее время, затраченное продюсером на выполнение initTransactions в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - txn-send-offsets-time-ns-total`	`jmx["{#JMXOBJ}","txn-send-offsets-time-ns-total",producer]`	Общее время, затраченное продюсером на выполнение sendOffsetsToTransaction в наносекундах	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID} - waiting-threads`	`jmx["{#JMXOBJ}","waiting-threads",producer]`	Количество пользовательских потоков, заблокированных в ожидании доступной памяти буфера для помещения записей в очередь	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`

Правило producer-topic-metrics#

Ключ: jmx.get[beans,"kafka.producer:type=producer-topic-metrics,client-id=*,topic=*"]

Прототипы элементов данных

Имя	Ключ	Описание	Тип	Интервал	История	Тренд
`{#CLIENTID}_{#TOPIC} - byte-rate`	`jmx["{#JMXOBJ}","byte-rate",producer-topic]`	Среднее количество байт, отправляемых в секунду для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - byte-total`	`jmx["{#JMXOBJ}","byte-total",producer-topic]`	Общее количество байт, отправленных для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - compression-rate`	`jmx["{#JMXOBJ}","compression-rate",producer-topic]`	Средняя степень сжатия пакетов записей для топика, определяемая как среднее значение отношения размера сжатого пакета к несжатому	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - record-error-rate`	`jmx["{#JMXOBJ}","record-error-rate",producer-topic]`	Среднее количество ошибок при отправке записей в секунду для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - record-error-total`	`jmx["{#JMXOBJ}","record-error-total",producer-topic]`	Общее количество ошибок при отправке записей для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - record-retry-rate`	`jmx["{#JMXOBJ}","record-retry-rate",producer-topic]`	Среднее количество повторных отправок записей в секунду для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - record-retry-total`	`jmx["{#JMXOBJ}","record-retry-total",producer-topic]`	Общее количество повторных отправок записей для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - record-send-rate`	`jmx["{#JMXOBJ}","record-send-rate",producer-topic]`	Среднее количество записей, отправляемых в секунду для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`
`{#CLIENTID}_{#TOPIC} - record-send-total`	`jmx["{#JMXOBJ}","record-send-total",producer-topic]`	Общее количество записей, отправленных для топика	`FLOAT`	`{$CORAX.ITEM.DELAY}`	`{$CORAX.ITEM.HISTORY}`	`{$CORAX.ITEM.TRENDS}`