Package org.apache.kafka.clients.producer.internals

Class KafkaProducerMetrics

java.lang.Object

org.apache.kafka.clients.producer.internals.KafkaProducerMetrics

All Implemented Interfaces:

AutoCloseable

public class KafkaProducerMetrics
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
static final String	GROUP

Constructor Summary

Constructors

Constructor	Description
KafkaProducerMetrics(org.apache.kafka.common.metrics.Metrics metrics)

Method Summary

Modifier and Type	Method	Description
void	close()
void	recordAbortTxn(long duration)
void	recordBeginTxn(long duration)
void	recordCommitTxn(long duration)
void	recordFlush(long duration)
void	recordInit(long duration)
void	recordMetadataWait(long duration)
void	recordSendOffsets(long duration)

Methods inherited from class java.lang.Object

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

Field Details

GROUP

public static final String GROUP

See Also:

• Constant Field Values

Constructor Details

KafkaProducerMetrics

public KafkaProducerMetrics(org.apache.kafka.common.metrics.Metrics metrics)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

recordFlush

public void recordFlush(long duration)

recordInit

public void recordInit(long duration)

recordBeginTxn

public void recordBeginTxn(long duration)

recordSendOffsets

public void recordSendOffsets(long duration)

recordCommitTxn

public void recordCommitTxn(long duration)

recordAbortTxn

public void recordAbortTxn(long duration)

recordMetadataWait

public void recordMetadataWait(long duration)