Package com.linkedin.venice.pubsub.api

Class PubSubProducerAdapterContext.Builder

java.lang.Object

com.linkedin.venice.pubsub.api.PubSubProducerAdapterContext.Builder

Enclosing class:

PubSubProducerAdapterContext

public static class PubSubProducerAdapterContext.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
PubSubProducerAdapterContext	build()
PubSubProducerAdapterContext.Builder	setBrokerAddress(String brokerAddress)
PubSubProducerAdapterContext.Builder	setCompressionType(String compressionType)
PubSubProducerAdapterContext.Builder	setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)
PubSubProducerAdapterContext.Builder	setProducerCompressionEnabled(boolean isProducerCompressionEnabled)
PubSubProducerAdapterContext.Builder	setProducerName(String producerName)
PubSubProducerAdapterContext.Builder	setPubSubMessageSerializer(PubSubMessageSerializer pubSubMessageSerializer)
PubSubProducerAdapterContext.Builder	setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)
PubSubProducerAdapterContext.Builder	setSecurityProtocol(PubSubSecurityProtocol securityProtocol)
PubSubProducerAdapterContext.Builder	setShouldValidateProducerConfigStrictly(boolean shouldValidateProducerConfigStrictly)
PubSubProducerAdapterContext.Builder	setVeniceProperties(VeniceProperties veniceProperties)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setProducerName

public PubSubProducerAdapterContext.Builder setProducerName(String producerName)

setBrokerAddress

public PubSubProducerAdapterContext.Builder setBrokerAddress(String brokerAddress)

setVeniceProperties

public PubSubProducerAdapterContext.Builder setVeniceProperties(VeniceProperties veniceProperties)

setSecurityProtocol

public PubSubProducerAdapterContext.Builder setSecurityProtocol(PubSubSecurityProtocol securityProtocol)

setMetricsRepository

public PubSubProducerAdapterContext.Builder setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)

setPubSubTopicRepository

public PubSubProducerAdapterContext.Builder setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)

setShouldValidateProducerConfigStrictly

public PubSubProducerAdapterContext.Builder setShouldValidateProducerConfigStrictly(boolean shouldValidateProducerConfigStrictly)

setPubSubMessageSerializer

public PubSubProducerAdapterContext.Builder setPubSubMessageSerializer(PubSubMessageSerializer pubSubMessageSerializer)

setProducerCompressionEnabled

public PubSubProducerAdapterContext.Builder setProducerCompressionEnabled(boolean isProducerCompressionEnabled)

setCompressionType

public PubSubProducerAdapterContext.Builder setCompressionType(String compressionType)

build

public PubSubProducerAdapterContext build()