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_CCLOUD
static final String	EVENT_PROCESSING_FAILURE_NON_CCLOUD
static final String	EVENT_QUEUE_PROCESSING_TIME_MS_CCLOUD
static final String	EVENT_QUEUE_PROCESSING_TIME_MS_NON_CCLOUD
static final String	FOLLOWERS_NOT_CATCHING_UP_CCLOUD
static final String	FOLLOWERS_NOT_CATCHING_UP_NON_CCLOUD
static final String	METRIC_GROUP_NAME_CCLOUD
static final String	METRIC_GROUP_NAME_NON_CCLOUD
static final String	METRIC_TYPE_NAME_CCLOUD
static final String	METRIC_TYPE_NAME_NON_CCLOUD
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_CCLOUD
static final String	STOPPING_PUSH_SESSIONS_NON_CCLOUD

Constructor Summary

Constructors

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

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_CCLOUD

public static final String METRIC_GROUP_NAME_CCLOUD

See Also:

• Constant Field Values

METRIC_TYPE_NAME_CCLOUD

public static final String METRIC_TYPE_NAME_CCLOUD

See Also:

• Constant Field Values

METRIC_GROUP_NAME_NON_CCLOUD

public static final String METRIC_GROUP_NAME_NON_CCLOUD

See Also:

• Constant Field Values

METRIC_TYPE_NAME_NON_CCLOUD

public static final String METRIC_TYPE_NAME_NON_CCLOUD

See Also:

• Constant Field Values

STOPPING_PUSH_SESSIONS_CCLOUD

public static final String STOPPING_PUSH_SESSIONS_CCLOUD

See Also:

• Constant Field Values

EVENT_QUEUE_PROCESSING_TIME_MS_CCLOUD

public static final String EVENT_QUEUE_PROCESSING_TIME_MS_CCLOUD

See Also:

• Constant Field Values

EVENT_PROCESSING_FAILURE_CCLOUD

public static final String EVENT_PROCESSING_FAILURE_CCLOUD

See Also:

• Constant Field Values

FOLLOWERS_NOT_CATCHING_UP_CCLOUD

public static final String FOLLOWERS_NOT_CATCHING_UP_CCLOUD

See Also:

• Constant Field Values

STOPPING_PUSH_SESSIONS_NON_CCLOUD

public static final String STOPPING_PUSH_SESSIONS_NON_CCLOUD

See Also:

• Constant Field Values

EVENT_QUEUE_PROCESSING_TIME_MS_NON_CCLOUD

public static final String EVENT_QUEUE_PROCESSING_TIME_MS_NON_CCLOUD

See Also:

• Constant Field Values

EVENT_PROCESSING_FAILURE_NON_CCLOUD

public static final String EVENT_PROCESSING_FAILURE_NON_CCLOUD

See Also:

• Constant Field Values

FOLLOWERS_NOT_CATCHING_UP_NON_CCLOUD

public static final String FOLLOWERS_NOT_CATCHING_UP_NON_CCLOUD

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

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,
 boolean isCCloud)

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)