Package com.linkedin.venice.unit.kafka.consumer.poll

Class BlockingObserverPollStrategy

java.lang.Object

com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy

com.linkedin.venice.unit.kafka.consumer.poll.BlockingObserverPollStrategy

All Implemented Interfaces:

PollStrategy

public class BlockingObserverPollStrategy
extends AbstractPollStrategy

This PollStrategy delegates polling to another implementation, and also executes an arbitrary function during each poll. This function is only allowed to observe, not to tamper with the data being polled. The function is executed synchronously, thus making it easy to reason about the state of the consumption stream at the time of the function's execution.

Field Summary

Fields inherited from class com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy

keepPollingWhenEmpty

Constructor Summary

Constructors

Constructor	Description
BlockingObserverPollStrategy(AbstractPollStrategy basePollStrategy, Consumer<PubSubTopicPartitionOffset> observer)

Method Summary

Modifier and Type	Method	Description
protected PubSubTopicPartitionOffset	getNextPoll(Map<PubSubTopicPartition,Long> offsets)

Methods inherited from class com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy

incrementOffset, poll

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingObserverPollStrategy

public BlockingObserverPollStrategy(AbstractPollStrategy basePollStrategy,
 Consumer<PubSubTopicPartitionOffset> observer)

Method Details

getNextPoll

protected PubSubTopicPartitionOffset getNextPoll(Map<PubSubTopicPartition,Long> offsets)

Specified by:

getNextPoll in class AbstractPollStrategy