com.opendxl.databus.producer.metric

Class ProducerMetricBuilder

java.lang.Object

com.opendxl.databus.producer.metric.ProducerMetricBuilder

public class ProducerMetricBuilder
extends java.lang.Object

ProducerMetricBuilder. This class is responsible to build a ProducerMetric instance.
ProducerMetricBuilder can build two producer metrics:

1. ClientIdMetric: a ProducerMetric which gives a result value related to metric associated to the clientId.
2. ClientIdTopicMetric: a ProducerMetric which gives a result value related to metric associated to the clientId and a specific topic.

Method Summary

Modifier and Type	Method and Description
static ProducerMetric	buildClientIdMetric(java.util.Map<MetricName,? extends org.apache.kafka.common.Metric> metrics, java.lang.String metricAttributeName, java.lang.String clientId) This method builds an instance of a ProducerMetric which gives a result value related to metric associated to the clientId.
static ProducerMetric	buildClientIdTopicMetric(java.util.Map<MetricName,? extends org.apache.kafka.common.Metric> metrics, java.lang.String metricAttributeName, java.lang.String clientId, TopicPartition topicPartition) This method builds an instance of a ProducerMetric which gives a result value related to metric associated to an specific topic provided as a parameter associated to the clientId.

Methods inherited from class java.lang.Object

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

Method Detail

buildClientIdMetric

public static ProducerMetric buildClientIdMetric(java.util.Map<MetricName,? extends org.apache.kafka.common.Metric> metrics,
                                                 java.lang.String metricAttributeName,
                                                 java.lang.String clientId)

This method builds an instance of a ProducerMetric which gives a result value related to metric associated to the clientId.

Parameters:

metrics - The Kafka list metrics.

metricAttributeName - The name of the Kafka metric that will be measured.

clientId - The clientId associated to the producer.

Returns:

A ProducerMetric instance.

buildClientIdTopicMetric

public static ProducerMetric buildClientIdTopicMetric(java.util.Map<MetricName,? extends org.apache.kafka.common.Metric> metrics,
                                                      java.lang.String metricAttributeName,
                                                      java.lang.String clientId,
                                                      TopicPartition topicPartition)

This method builds an instance of a ProducerMetric which gives a result value related to metric associated to an specific topic provided as a parameter associated to the clientId.

Parameters:

metrics - The Kafka list metrics.

metricAttributeName - The name of the Kafka metric that will be measured.

clientId - The clientId associated to the producer.

topicPartition - The topicPartition which contains the topic name.

Returns:

A ProducerMetric instance.