Package com.linkedin.venice.pubsub.api

Class PubSubProducerAdapterContext

java.lang.Object

com.linkedin.venice.pubsub.api.PubSubProducerAdapterContext

public class PubSubProducerAdapterContext
extends Object

Encapsulates all dependencies and configurations required to create a producer using a producer factory. This class serves as a unified context for managing producer setup across different PubSub systems.

Common configurations applicable to all PubSub implementations should be defined as member variables in this class, while system-specific configurations should be stored in VeniceProperties.

Each PubSub implementation is expected to interpret both the common configurations and the PubSub-specific settings based on namespace-scoped configurations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PubSubProducerAdapterContext.Builder

Method Summary

Modifier and Type	Method	Description
String	getBrokerAddress()
String	getCompressionType()
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
String	getProducerName()
PubSubMessageSerializer	getPubSubMessageSerializer()
PubSubTopicRepository	getPubSubTopicRepository()
PubSubSecurityProtocol	getSecurityProtocol()
VeniceProperties	getVeniceProperties()
boolean	isProducerCompressionEnabled()
boolean	shouldValidateProducerConfigStrictly()

Methods inherited from class java.lang.Object

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

Method Details

getProducerName

public String getProducerName()

getBrokerAddress

public String getBrokerAddress()

getVeniceProperties

public VeniceProperties getVeniceProperties()

getSecurityProtocol

public PubSubSecurityProtocol getSecurityProtocol()

getMetricsRepository

public io.tehuti.metrics.MetricsRepository getMetricsRepository()

getPubSubTopicRepository

public PubSubTopicRepository getPubSubTopicRepository()

shouldValidateProducerConfigStrictly

public boolean shouldValidateProducerConfigStrictly()

getPubSubMessageSerializer

public PubSubMessageSerializer getPubSubMessageSerializer()

isProducerCompressionEnabled

public boolean isProducerCompressionEnabled()

getCompressionType

public String getCompressionType()