Package com.linkedin.venice.utils

Class PubSubHelper

java.lang.Object

com.linkedin.venice.utils.PubSubHelper

public class PubSubHelper
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PubSubHelper.MutablePubSubMessage

Constructor Summary

Constructors

Constructor	Description
PubSubHelper()

Method Summary

Modifier and Type	Method	Description
static KafkaKey	getDummyKey()
static KafkaKey	getDummyKey(boolean isControlMessage)
static PubSubHelper.MutablePubSubMessage	getDummyPubSubMessage(boolean isControlMessage)
static KafkaMessageEnvelope	getDummyValue()
static KafkaMessageEnvelope	getDummyValue(long producerMessageTimestamp)
static java.util.List<PubSubHelper.MutablePubSubMessage>	produceMessages(PubSubProducerAdapter pubSubProducerAdapter, PubSubTopicPartition topicPartition, int messageCount, long delayBetweenMessagesInMs, boolean controlMessages)

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubHelper

public PubSubHelper()

Method Detail

getDummyKey

public static KafkaKey getDummyKey()

getDummyKey

public static KafkaKey getDummyKey(boolean isControlMessage)

getDummyValue

public static KafkaMessageEnvelope getDummyValue()

getDummyValue

public static KafkaMessageEnvelope getDummyValue(long producerMessageTimestamp)

getDummyPubSubMessage

public static PubSubHelper.MutablePubSubMessage getDummyPubSubMessage(boolean isControlMessage)

produceMessages

public static java.util.List<PubSubHelper.MutablePubSubMessage> produceMessages(PubSubProducerAdapter pubSubProducerAdapter,
                                                                                PubSubTopicPartition topicPartition,
                                                                                int messageCount,
                                                                                long delayBetweenMessagesInMs,
                                                                                boolean controlMessages)
                                                                         throws java.lang.InterruptedException,
                                                                                java.util.concurrent.ExecutionException,
                                                                                java.util.concurrent.TimeoutException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException