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

Interface PollStrategy

All Known Implementing Classes:

AbstractPollStrategy, ArbitraryOrderingPollStrategy, BlockingObserverPollStrategy, CompositePollStrategy, DuplicatingPollStrategy, FilteringPollStrategy, RandomPollStrategy

public interface PollStrategy

This interface is used inside of the MockInMemoryConsumer in order to mess around with the way messages are delivered to the consuming code. This is used in unit tests in order to control message deliver order, introduce duplicates, inject new arbitrary messages, skip messages...

Method Summary

Modifier and Type	Method	Description
java.util.Map<PubSubTopicPartition,java.util.List<PubSubMessage<KafkaKey,KafkaMessageEnvelope,java.lang.Long>>>	poll(InMemoryKafkaBroker broker, java.util.Map<PubSubTopicPartition,java.lang.Long> offsets, long timeout)

Method Detail

poll

java.util.Map<PubSubTopicPartition,java.util.List<PubSubMessage<KafkaKey,KafkaMessageEnvelope,java.lang.Long>>> poll(InMemoryKafkaBroker broker,
                                                                                                                                       java.util.Map<PubSubTopicPartition,java.lang.Long> offsets,
                                                                                                                                       long timeout)