org.apache.hadoop.metrics2.sink

クラス KafkaSink

java.lang.Object

org.apache.hadoop.metrics2.sink.KafkaSink

すべての実装されたインタフェース:

Closeable, AutoCloseable, MetricsPlugin, MetricsSink

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class KafkaSink
extends Object
implements MetricsSink, Closeable

A metrics sink that writes to a Kafka broker. This requires you to configure a broker_list and a topic in the metrics2 configuration file. The broker_list must contain a comma-separated list of kafka broker host and ports. The topic will contain only one topic.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
static String	BROKER_LIST
static String	TOPIC

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
KafkaSink()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close()
void	flush() Flush any buffered metrics
void	init(org.apache.commons.configuration.SubsetConfiguration conf) Initialize the plugin
void	putMetrics(MetricsRecord record) Put a metrics record in the sink
void	setProducer(org.apache.kafka.clients.producer.Producer<Integer,byte[]> p)

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

フィールドの詳細

BROKER_LIST

public static final String BROKER_LIST

関連項目:

定数フィールド値

TOPIC

public static final String TOPIC

関連項目:

定数フィールド値

コンストラクタの詳細

KafkaSink

public KafkaSink()

メソッドの詳細

setProducer

public void setProducer(org.apache.kafka.clients.producer.Producer<Integer,byte[]> p)

init

public void init(org.apache.commons.configuration.SubsetConfiguration conf)

インタフェースからコピーされた説明: MetricsPlugin

Initialize the plugin

定義:

init インタフェース内 MetricsPlugin

パラメータ:

conf - the configuration object for the plugin

putMetrics

public void putMetrics(MetricsRecord record)

インタフェースからコピーされた説明: MetricsSink

Put a metrics record in the sink

定義:

putMetrics インタフェース内 MetricsSink

パラメータ:

record - the record to put

flush

public void flush()

インタフェースからコピーされた説明: MetricsSink

Flush any buffered metrics

定義:

flush インタフェース内 MetricsSink

close

public void close()
           throws IOException

定義:

close インタフェース内 Closeable

定義:

close インタフェース内 AutoCloseable

例外:

IOException