Samza JMX

默認(rèn)情況下，Samza 的容器和 YARN ApplicationMaster 啟用 JMX。JMX可用于管理 JVM; 例如，您可以使用JDK中包含的 jconsole 連接到它。

您可以告訴 Samza 發(fā)布其內(nèi)部指標(biāo)，以及您定義的任何自定義指標(biāo)，作為 JMX MBean。要啟用此功能，請(qǐng)?jiān)谧鳂I(yè)配置中設(shè)置以下屬性：

# Define a Samza metrics reporter called "jmx", which publishes to JMX
metrics.reporter.jmx.class=org.apache.samza.metrics.reporter.JmxReporterFactory

# Use it (if you have multiple reporters defined, separate them with commas)
metrics.reporters=jmx

JMX 需要配置為使用特定端口，但在分布式環(huán)境中，無法預(yù)先知道運(yùn)行容器的計(jì)算機(jī)上哪些端口可用。所以 Samza 隨機(jī)選擇 JMX 端口。如果需要連接，可以通過查看容器的日志來找到該端口，該日志將報(bào)告 JMX 服務(wù)器的詳細(xì)信息如下：

2014-06-02 21:50:17 JmxServer [INFO] According to InetAddress.getLocalHost.getHostName we are samza-grid-1234.example.com
2014-06-02 21:50:17 JmxServer [INFO] Started JmxServer registry port=50214 server port=50215 url=service:jmx:rmi://localhost:50215/jndi/rmi://localhost:50214/jmxrmi
2014-06-02 21:50:17 JmxServer [INFO] If you are tunneling, you might want to try JmxServer registry port=50214 server port=50215 url=service:jmx:rmi://samza-grid-1234.example.com:50215/jndi/rmi://samza-grid-1234.example.com:50214/jmxrmi

JobRunner  ?