org.thales.punch.kafka.impl

Class MonitoredPartition

java.lang.Object

org.thales.punch.kafka.impl.MonitoredPartition

Direct Known Subclasses:

AbstractPartition

public class MonitoredPartition
extends Object

This class holds per partition metrics.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
protected com.codahale.metrics.Timer	commitLatency latency in milliseconds of kafka offset commit
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	committedOffsetGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	currentDelayGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	currentTimestampGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	earliestOffsetGauge
protected com.codahale.metrics.Histogram	fetchSize size of messages in bytes
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	latestOffsetGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	messagesCommitBacklogGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	messagesFetchBacklogGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	messagesPersistedBacklogGauge
protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long>	messagesReplayableGauge
protected org.thales.punch.libraries.metrics.api.IMetricContext	metricsContext the metrics context in charge of periodically publishing our metrics with the adequate names and tags
protected com.codahale.metrics.Meter	msgFetchRate rate (per second) of messages read from a partition
protected com.codahale.metrics.Meter	offsetAckRate offset acknowledgement rate
protected com.codahale.metrics.Meter	offsetFailRate offset acknowledgement rate

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MonitoredPartition(org.thales.punch.libraries.metrics.api.IMetricContext mc, String topic, int partitionNumber, Long offsetWatchDogTimeout)

Method Summary

Modifier and Type	Method and Description
void	close() Closing means unregistering all our metrics.

Methods inherited from class java.lang.Object

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

Field Detail

metricsContext

protected org.thales.punch.libraries.metrics.api.IMetricContext metricsContext

the metrics context in charge of periodically publishing our metrics with the adequate names and tags

msgFetchRate

protected com.codahale.metrics.Meter msgFetchRate

rate (per second) of messages read from a partition

fetchSize

protected com.codahale.metrics.Histogram fetchSize

size of messages in bytes

offsetAckRate

protected com.codahale.metrics.Meter offsetAckRate

offset acknowledgement rate

offsetFailRate

protected com.codahale.metrics.Meter offsetFailRate

offset acknowledgement rate

commitLatency

protected com.codahale.metrics.Timer commitLatency

latency in milliseconds of kafka offset commit

committedOffsetGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> committedOffsetGauge

earliestOffsetGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> earliestOffsetGauge

latestOffsetGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> latestOffsetGauge

messagesFetchBacklogGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> messagesFetchBacklogGauge

messagesCommitBacklogGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> messagesCommitBacklogGauge

messagesPersistedBacklogGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> messagesPersistedBacklogGauge

currentTimestampGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> currentTimestampGauge

currentDelayGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> currentDelayGauge

messagesReplayableGauge

protected org.thales.punch.libraries.metrics.api.BlackboardGauge<Long> messagesReplayableGauge

Constructor Detail

MonitoredPartition

protected MonitoredPartition(org.thales.punch.libraries.metrics.api.IMetricContext mc,
                             String topic,
                             int partitionNumber,
                             Long offsetWatchDogTimeout)

Method Detail

close

public void close()

Closing means unregistering all our metrics.