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

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

Related Packages

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

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.
PollStrategy	This interface is used inside of the MockInMemoryConsumer in order to mess around with the way messages are delivered to the consuming code.
PubSubTopicPartitionOffset
RandomPollStrategy	A simple PollStrategy which delivers messages from any partition, while respecting the ordering guarantee of individual partitions.