нет метрики jmx в нифи

Question

Я хотел бы извлечь метрики kafka и обнаружил, что это можно сделать через JMX с использованием jconsole. Но мне нужно создать программный способ для этого и подумать, что nifi будет отличным способом использовать эти метрики, но не может найти процесс, который делает это. Кто-нибудь предложит способ сделать это или подтвердит, что нет способа сделать это с помощью nifi? Если нет, то может кто-нибудь дать предложения о том, как это сделать или ссылки на примеры?

Answer 1

Я бы порекомендовал исследовать выполнение операций JMX через HTTP. Существует библиотека под названием Jolokia , которая предоставляет возможности JMX с использованием JSON по HTTP (здесь сообщение в блоге , описывающее подход одного разработчика). Вы можете использовать InvokeHTTP процессоры для выполнения этих вызовов или, если вам нужно объединить несколько вызовов в логические атомарные единицы, вы можете использовать ExecuteScript процессоры. Вы также можете написать пользовательскую Службу контроллера или Отчетную задачу , которая предоставляла эту услугу нескольким компонентам.