org.thales.punch.kafka.impl

Class AbstractPartition<K,V>

java.lang.Object

org.thales.punch.kafka.impl.MonitoredPartition

org.thales.punch.kafka.impl.AbstractPartition<K,V>

Type Parameters:

K - record key type

V - record value type

All Implemented Interfaces:

IPartition

Direct Known Subclasses:

OffsetTreePartitionImpl, StandardPartitionImpl

public abstract class AbstractPartition<K,V>
extends MonitoredPartition
implements IPartition

Our IPartition abstract implementation. It only provides the basics.

Author:

dimi, cedric

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V>	consumer the consumer
protected Long	earliestOffset
protected Long	latestOffset
protected int	partitionNumber our partition number
protected String	topic our topic

Fields inherited from class org.thales.punch.kafka.impl.MonitoredPartition

commitLatency, committedOffsetGauge, currentDelayGauge, currentTimestampGauge, earliestOffsetGauge, fetchSize, latestOffsetGauge, messagesCommitBacklogGauge, messagesFetchBacklogGauge, messagesPersistedBacklogGauge, messagesReplayableGauge, metricsContext, msgFetchRate, offsetAckRate, offsetFailRate

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractPartition(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.thales.punch.libraries.metrics.api.IMetricContext mc, String topic, int partitionNumber, Long offsetWatchDogTimeout)

Method Summary

Modifier and Type	Method and Description
void	attach(Object o) Attach an object to this partition.
Object	getAttachment()
int	getPartitionNumber()
String	getTopic()
protected abstract void	onReceive(IRecordHandler<K,V> receiver, org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
protected void	setEarliestOffset(Long value)
protected void	setLatestOffset(Long value)

Methods inherited from class org.thales.punch.kafka.impl.MonitoredPartition

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.kafka.api.IPartition

ack, close, commit, commit, fail, rewind

Field Detail

partitionNumber

protected int partitionNumber

our partition number

topic

protected String topic

our topic

consumer

protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer

the consumer

earliestOffset

protected Long earliestOffset

latestOffset

protected Long latestOffset

Constructor Detail

AbstractPartition

protected AbstractPartition(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer,
                            org.thales.punch.libraries.metrics.api.IMetricContext mc,
                            String topic,
                            int partitionNumber,
                            Long offsetWatchDogTimeout)

Parameters:

mc - the metric context

partitionNumber - the partition number

offsetWatchDogTimeout -

Method Detail

getPartitionNumber

public int getPartitionNumber()

Specified by:

getPartitionNumber in interface IPartition

Returns:

the associated partition number

getTopic

public String getTopic()

Specified by:

getTopic in interface IPartition

Returns:

the owner topic

attach

public void attach(Object o)

Description copied from interface: IPartition

Attach an object to this partition. You can then retrieve it using IPartition.getAttachment().

Specified by:

attach in interface IPartition

Parameters:

o - the object to attach

getAttachment

public Object getAttachment()

Specified by:

getAttachment in interface IPartition

Returns:

the attached object if any

setEarliestOffset

protected void setEarliestOffset(Long value)

setLatestOffset

protected void setLatestOffset(Long value)

onReceive

protected abstract void onReceive(IRecordHandler<K,V> receiver,
                                  org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)