Package io.confluent.kafka.replication.push.metrics

Class PushReplicationManagerMetrics

java.lang.Object

io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics

All Implemented Interfaces:

AutoCloseable

public class PushReplicationManagerMetrics
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EVENT_PROCESSING_FAILURE
static final String	EVENT_QUEUE_PROCESSING_TIME_MS
static final String	FOLLOWERS_NOT_CATCHING_UP
static final String	METRIC_GROUP_NAME
static final String	METRIC_TYPE_NAME
final org.apache.kafka.common.metrics.Metrics	metrics
static final String	PUSH_MANAGER_MEMORY_BYTES_USED
static final String	PUSH_SESSION_END_COUNT
static final String	STOPPING_PUSH_SESSIONS

Constructor Summary

Constructors

Constructor	Description
PushReplicationManagerMetrics(org.apache.kafka.common.metrics.Metrics metrics, com.yammer.metrics.core.Meter replicationBytesOutMeter, ReplicationQuotaRecorder replicationQuotaRecorder)

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.kafka.common.metrics.KafkaMetric	eventQueueProcessingTimeMetric(String histogramMetricSuffix)
void	incrementEventProcessingFailureCount()
void	incrementFollowersNotCatchingUpCount()
void	incrementPushSessionEndCount(PushSessionEndReason pushSessionEndReason)
void	recordPartitionReplicationBytesOut(org.apache.kafka.common.Uuid topicId, int partitionIndex, long bytes)
void	recordReplicationBytesOut(long bytes)
void	registerMemoryBytesUsedGauge(com.yammer.metrics.core.Gauge<Long> memoryBytesUsedGauge)
void	registerStoppingPushSessionSupplier(Supplier<Integer> supplier)
void	updateEventQueueProcessingTime(long queueTimeMs)

Methods inherited from class java.lang.Object

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

Field Details

METRIC_GROUP_NAME

public static final String METRIC_GROUP_NAME

See Also:

• Constant Field Values

METRIC_TYPE_NAME

public static final String METRIC_TYPE_NAME

See Also:

• Constant Field Values

EVENT_PROCESSING_FAILURE

public static final String EVENT_PROCESSING_FAILURE

See Also:

• Constant Field Values

EVENT_QUEUE_PROCESSING_TIME_MS

public static final String EVENT_QUEUE_PROCESSING_TIME_MS

See Also:

• Constant Field Values

PUSH_MANAGER_MEMORY_BYTES_USED

public static final String PUSH_MANAGER_MEMORY_BYTES_USED

See Also:

• Constant Field Values

PUSH_SESSION_END_COUNT

public static final String PUSH_SESSION_END_COUNT

See Also:

• Constant Field Values

STOPPING_PUSH_SESSIONS

public static final String STOPPING_PUSH_SESSIONS

See Also:

• Constant Field Values

FOLLOWERS_NOT_CATCHING_UP

public static final String FOLLOWERS_NOT_CATCHING_UP

See Also:

• Constant Field Values

metrics

public final org.apache.kafka.common.metrics.Metrics metrics

Constructor Details

PushReplicationManagerMetrics

public PushReplicationManagerMetrics(org.apache.kafka.common.metrics.Metrics metrics,
 com.yammer.metrics.core.Meter replicationBytesOutMeter,
 ReplicationQuotaRecorder replicationQuotaRecorder)

Method Details

recordPartitionReplicationBytesOut

public void recordPartitionReplicationBytesOut(org.apache.kafka.common.Uuid topicId,
 int partitionIndex,
 long bytes)

recordReplicationBytesOut

public void recordReplicationBytesOut(long bytes)

updateEventQueueProcessingTime

public void updateEventQueueProcessingTime(long queueTimeMs)

incrementPushSessionEndCount

public void incrementPushSessionEndCount(PushSessionEndReason pushSessionEndReason)

incrementEventProcessingFailureCount

public void incrementEventProcessingFailureCount()

incrementFollowersNotCatchingUpCount

public void incrementFollowersNotCatchingUpCount()

registerMemoryBytesUsedGauge

public void registerMemoryBytesUsedGauge(com.yammer.metrics.core.Gauge<Long> memoryBytesUsedGauge)

registerStoppingPushSessionSupplier

public void registerStoppingPushSessionSupplier(Supplier<Integer> supplier)

close

public void close()

Specified by:

close in interface AutoCloseable

eventQueueProcessingTimeMetric

public org.apache.kafka.common.metrics.KafkaMetric eventQueueProcessingTimeMetric(String histogramMetricSuffix)