Package com.linkedin.venice.utils

Class PubSubHelper

java.lang.Object

com.linkedin.venice.utils.PubSubHelper

public class PubSubHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PubSubHelper.MutableDefaultPubSubMessage

Constructor Summary

Constructors

Constructor	Description
PubSubHelper()

Method Summary

Modifier and Type	Method	Description
static KafkaKey	getDummyKey()
static KafkaKey	getDummyKey(boolean isControlMessage)
static PubSubHelper.MutableDefaultPubSubMessage	getDummyPubSubMessage(boolean isControlMessage)
static KafkaMessageEnvelope	getDummyValue()
static KafkaMessageEnvelope	getDummyValue(long producerMessageTimestamp)
static List<PubSubHelper.MutableDefaultPubSubMessage>	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 Details

PubSubHelper

public PubSubHelper()

Method Details

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.MutableDefaultPubSubMessage getDummyPubSubMessage(boolean isControlMessage)

produceMessages

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

Throws:

InterruptedException

ExecutionException

TimeoutException