Package com.linkedin.venice.pubsub

Class PubSubConsumerAdapterContext.Builder

java.lang.Object

com.linkedin.venice.pubsub.PubSubConsumerAdapterContext.Builder

Enclosing class:

PubSubConsumerAdapterContext

public static class PubSubConsumerAdapterContext.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
PubSubConsumerAdapterContext	build()
PubSubConsumerAdapterContext.Builder	setConsumerName(String consumerName)
PubSubConsumerAdapterContext.Builder	setIsOffsetCollectionEnabled(boolean shouldValidateProducerConfigStrictly)
PubSubConsumerAdapterContext.Builder	setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)
PubSubConsumerAdapterContext.Builder	setPubSubBrokerAddress(String pubSubBrokerAddress)
PubSubConsumerAdapterContext.Builder	setPubSubMessageDeserializer(PubSubMessageDeserializer pubSubMessageDeserializer)
PubSubConsumerAdapterContext.Builder	setPubSubPositionTypeRegistry(PubSubPositionTypeRegistry pubSubPositionTypeRegistry)
PubSubConsumerAdapterContext.Builder	setPubSubSecurityProtocol(PubSubSecurityProtocol pubSubSecurityProtocol)
PubSubConsumerAdapterContext.Builder	setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)
PubSubConsumerAdapterContext.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

setConsumerName

public PubSubConsumerAdapterContext.Builder setConsumerName(String consumerName)

setPubSubBrokerAddress

public PubSubConsumerAdapterContext.Builder setPubSubBrokerAddress(String pubSubBrokerAddress)

setVeniceProperties

public PubSubConsumerAdapterContext.Builder setVeniceProperties(VeniceProperties veniceProperties)

setPubSubSecurityProtocol

public PubSubConsumerAdapterContext.Builder setPubSubSecurityProtocol(PubSubSecurityProtocol pubSubSecurityProtocol)

setMetricsRepository

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

setPubSubTopicRepository

public PubSubConsumerAdapterContext.Builder setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)

setIsOffsetCollectionEnabled

public PubSubConsumerAdapterContext.Builder setIsOffsetCollectionEnabled(boolean shouldValidateProducerConfigStrictly)

setPubSubMessageDeserializer

public PubSubConsumerAdapterContext.Builder setPubSubMessageDeserializer(PubSubMessageDeserializer pubSubMessageDeserializer)

setPubSubPositionTypeRegistry

public PubSubConsumerAdapterContext.Builder setPubSubPositionTypeRegistry(PubSubPositionTypeRegistry pubSubPositionTypeRegistry)

build

public PubSubConsumerAdapterContext build()