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

Class RandomPollStrategy

java.lang.Object

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

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

All Implemented Interfaces:

PollStrategy

public class RandomPollStrategy
extends AbstractPollStrategy

A simple PollStrategy which delivers messages from any partition, while respecting the ordering guarantee of individual partitions. The resulting consumption order is non-deterministic.

Field Summary

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

keepPollingWhenEmpty

Constructor Summary

Constructors

Constructor	Description
RandomPollStrategy()
RandomPollStrategy(boolean keepPollingWhenEmpty)
RandomPollStrategy(int maxMessagePerPoll)

Method Summary

Modifier and Type	Method	Description
protected PubSubTopicPartitionOffset	getNextPoll(java.util.Map<PubSubTopicPartition,java.lang.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 Detail

RandomPollStrategy

public RandomPollStrategy()

RandomPollStrategy

public RandomPollStrategy(int maxMessagePerPoll)

RandomPollStrategy

public RandomPollStrategy(boolean keepPollingWhenEmpty)

Method Detail

getNextPoll

protected PubSubTopicPartitionOffset getNextPoll(java.util.Map<PubSubTopicPartition,java.lang.Long> offsets)

Specified by:

getNextPoll in class AbstractPollStrategy