Package io.streamthoughts.azkarra.api.streams.listener

Class CompositeStateRestoreListener

java.lang.Object

io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener

All Implemented Interfaces:

KafkaStreamsContainerAware, org.apache.kafka.streams.processor.StateRestoreListener

public class CompositeStateRestoreListener
extends Object
implements org.apache.kafka.streams.processor.StateRestoreListener, KafkaStreamsContainerAware

A StateRestoreListener that delegates to one or more StateRestoreListener in order.

Constructor Summary

Constructors

Constructor	Description
CompositeStateRestoreListener(Collection<org.apache.kafka.streams.processor.StateRestoreListener> listeners)	Creates a new CompositeStateRestoreListener instance.

Method Summary

Modifier and Type	Method	Description
void	addListener(org.apache.kafka.streams.processor.StateRestoreListener listener)
void	onBatchRestored(org.apache.kafka.common.TopicPartition topicPartition, String storeName, long batchEndOffset, long numRestored)
void	onRestoreEnd(org.apache.kafka.common.TopicPartition topicPartition, String storeName, long totalRestored)
void	onRestoreStart(org.apache.kafka.common.TopicPartition topicPartition, String storeName, long startingOffset, long endingOffset)
void	setKafkaStreamsContainer(KafkaStreamsContainer container)	Sets the KafkaStreamsContainer that this object runs in.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeStateRestoreListener

public CompositeStateRestoreListener(Collection<org.apache.kafka.streams.processor.StateRestoreListener> listeners)

Creates a new CompositeStateRestoreListener instance.

Parameters:

listeners - the list of StateRestoreListener.

Method Detail

addListener

public void addListener(org.apache.kafka.streams.processor.StateRestoreListener listener)

onRestoreStart

public void onRestoreStart(org.apache.kafka.common.TopicPartition topicPartition,
                           String storeName,
                           long startingOffset,
                           long endingOffset)

Specified by:

onRestoreStart in interface org.apache.kafka.streams.processor.StateRestoreListener

onBatchRestored

public void onBatchRestored(org.apache.kafka.common.TopicPartition topicPartition,
                            String storeName,
                            long batchEndOffset,
                            long numRestored)

Specified by:

onBatchRestored in interface org.apache.kafka.streams.processor.StateRestoreListener

onRestoreEnd

public void onRestoreEnd(org.apache.kafka.common.TopicPartition topicPartition,
                         String storeName,
                         long totalRestored)

Specified by:

onRestoreEnd in interface org.apache.kafka.streams.processor.StateRestoreListener

setKafkaStreamsContainer

public void setKafkaStreamsContainer(KafkaStreamsContainer container)

Sets the KafkaStreamsContainer that this object runs in.

Specified by:

setKafkaStreamsContainer in interface KafkaStreamsContainerAware

Parameters:

container - the KafkaStreamsContainer.