我想提取kafka度量，并发现这可以通过jmx使用jconsole来完成。但是我需要创建一个程序化的方法来实现这一点，我认为nifi是使用这些度量的一个很好的方法，但是找不到一个这样做的过程。有人会建议一个方法来做这件事，或确认没有办法做这件事与nifi？如果没有，请有人提供如何做到这一点的建议或链接的例子？
yqkkidmi1#
我建议您研究一下如何执行jmxoverhttp操作。有一个名为jolokia的库，它使用json over http公开jmx特性（下面是一篇描述开发人员方法的博客文章）。你可以用 InvokeHTTP 处理器来进行这些调用，或者如果需要将多个调用捆绑到逻辑原子单元中，可以使用 ExecuteScript 处理器。您还可以编写一个定制的控制器服务或报告任务，将此服务提供给多个组件。
InvokeHTTP
ExecuteScript
1条答案
按热度按时间yqkkidmi1#
我建议您研究一下如何执行jmxoverhttp操作。有一个名为jolokia的库，它使用json over http公开jmx特性（下面是一篇描述开发人员方法的博客文章）。你可以用
InvokeHTTP处理器来进行这些调用，或者如果需要将多个调用捆绑到逻辑原子单元中，可以使用ExecuteScript处理器。您还可以编写一个定制的控制器服务或报告任务，将此服务提供给多个组件。