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

Interface Summary

Interface	Description
PollStrategy	This interface is used inside of the MockInMemoryConsumer in order to mess around with the way messages are delivered to the consuming code.

Class Summary

Class	Description
AbstractPollStrategy	A base class which encapsulates the common plumbing needed by all PollStrategy implementations.
ArbitraryOrderingPollStrategy	A PollStrategy implementation which delivers messages in the order specified at construction time.
BlockingObserverPollStrategy	This PollStrategy delegates polling to another implementation, and also executes an arbitrary function during each poll.
CompositePollStrategy	A PollStrategy implementation which takes a queue of many poll strategies.
DuplicatingPollStrategy	A PollStrategy implementation which can introduce duplicates.
FilteringPollStrategy	A PollStrategy implementation which can pluck out records from the stream.
PubSubTopicPartitionOffset
RandomPollStrategy	A simple PollStrategy which delivers messages from any partition, while respecting the ordering guarantee of individual partitions.