org.apache.kylin.metrics.lib.impl.kafka

Class KafkaActiveReserviorListener

java.lang.Object

org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

All Implemented Interfaces:

Closeable, AutoCloseable, EventListener, ActiveReservoirListener

public abstract class KafkaActiveReserviorListener
extends Object
implements ActiveReservoirListener

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	logger
protected Long	maxBlockMs
protected int	maxRecordForLogNum
protected int	maxRecordSkipForLogNum
static long	TOPIC_AVAILABLE_TAG
protected ConcurrentHashMap<String,Long>	topicsIfAvailable

Constructor Summary

Constructors

Constructor and Description
KafkaActiveReserviorListener()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	checkAvailable(String topic)
protected abstract String	decorateTopic(String topic)
boolean	onRecordUpdate(List<Record> records)
protected abstract void	send(String topic, Record record, org.apache.kafka.clients.producer.Callback callback)
protected void	sendWrapper(String topic, Record record, org.apache.kafka.clients.producer.Callback callback)
protected void	setUnAvailable(String topic)
protected abstract void	tryFetchMetadataFor(String topic)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kylin.metrics.lib.ActiveReservoirListener

close

Field Detail

TOPIC_AVAILABLE_TAG

public static final long TOPIC_AVAILABLE_TAG

See Also:

Constant Field Values

logger

protected static final org.slf4j.Logger logger

maxBlockMs

protected Long maxBlockMs

maxRecordForLogNum

protected int maxRecordForLogNum

maxRecordSkipForLogNum

protected int maxRecordSkipForLogNum

topicsIfAvailable

protected ConcurrentHashMap<String,Long> topicsIfAvailable

Constructor Detail

KafkaActiveReserviorListener

public KafkaActiveReserviorListener()

Method Detail

decorateTopic

protected abstract String decorateTopic(String topic)

tryFetchMetadataFor

protected abstract void tryFetchMetadataFor(String topic)

send

protected abstract void send(String topic,
        Record record,
        org.apache.kafka.clients.producer.Callback callback)

sendWrapper

protected void sendWrapper(String topic,
               Record record,
               org.apache.kafka.clients.producer.Callback callback)

onRecordUpdate

public boolean onRecordUpdate(List<Record> records)

Specified by:

onRecordUpdate in interface ActiveReservoirListener

checkAvailable

protected boolean checkAvailable(String topic)

setUnAvailable

protected void setUnAvailable(String topic)