Package com.linkedin.venice.pubsub

Class PubSubConsumerAdapterContext

java.lang.Object

com.linkedin.venice.pubsub.PubSubConsumerAdapterContext

public class PubSubConsumerAdapterContext
extends Object

Encapsulates all dependencies and configurations required to create a consumer using a consumer factory. This class serves as a unified context for managing consumer 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	PubSubConsumerAdapterContext.Builder

Method Summary

Modifier and Type	Method	Description
String	getConsumerName()
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
String	getPubSubBrokerAddress()
Function<String,String>	getPubSubEncryptionKeyUrnLookup()
PubSubMessageDeserializer	getPubSubMessageDeserializer()
PubSubPositionTypeRegistry	getPubSubPositionTypeRegistry()
PubSubSecurityProtocol	getPubSubSecurityProtocol()
PubSubTopicRepository	getPubSubTopicRepository()
AsyncStoreChangeNotifier	getStoreChangeNotifier()
VeniceProperties	getVeniceProperties()
boolean	isOffsetCollectionEnabled()

Methods inherited from class java.lang.Object

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

Method Details

getConsumerName

public String getConsumerName()

getPubSubBrokerAddress

public String getPubSubBrokerAddress()

getVeniceProperties

public VeniceProperties getVeniceProperties()

getPubSubSecurityProtocol

public PubSubSecurityProtocol getPubSubSecurityProtocol()

getMetricsRepository

public io.tehuti.metrics.MetricsRepository getMetricsRepository()

getPubSubTopicRepository

public PubSubTopicRepository getPubSubTopicRepository()

isOffsetCollectionEnabled

public boolean isOffsetCollectionEnabled()

getPubSubMessageDeserializer

public PubSubMessageDeserializer getPubSubMessageDeserializer()

getPubSubPositionTypeRegistry

public PubSubPositionTypeRegistry getPubSubPositionTypeRegistry()

getStoreChangeNotifier

public AsyncStoreChangeNotifier getStoreChangeNotifier()

getPubSubEncryptionKeyUrnLookup

public Function<String,String> getPubSubEncryptionKeyUrnLookup()

See Also:

• PubSubContext.getPubSubEncryptionKeyUrnLookup()