Package com.linkedin.davinci.consumer

Class VeniceChangelogConsumerClientFactory

java.lang.Object

com.linkedin.davinci.consumer.VeniceChangelogConsumerClientFactory

public class VeniceChangelogConsumerClientFactory
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	VeniceChangelogConsumerClientFactory.ViewClassGetter

Field Summary

Fields

Modifier and Type	Field	Description
protected VeniceChangelogConsumerClientFactory.ViewClassGetter	viewClassGetter

Constructor Summary

Constructors

Constructor	Description
VeniceChangelogConsumerClientFactory(ChangelogClientConfig globalChangelogClientConfig, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
<K,V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(java.lang.String storeName)
<K,V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(java.lang.String storeName, java.lang.String consumerId)
<K,V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(java.lang.String storeName, java.lang.String consumerId, java.lang.Class clazz)	Creates a BootstrappingVeniceChangelogConsumer with consumer id.
<K,V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(java.lang.String storeName)	Default method to create a VeniceChangelogConsumer given a storeName.
<K,V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(java.lang.String storeName, java.lang.String consumerId)
<K,V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(java.lang.String storeName, java.lang.String consumerId, java.lang.Class clazz)	Creates a VeniceChangelogConsumer with consumer id.
protected void	setConsumer(PubSubConsumerAdapter consumer)
protected void	setD2ControllerClient(D2ControllerClient d2ControllerClient)
protected void	setViewClassGetter(VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter)

Methods inherited from class java.lang.Object

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

Field Detail

viewClassGetter

protected VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter

Constructor Detail

VeniceChangelogConsumerClientFactory

public VeniceChangelogConsumerClientFactory(ChangelogClientConfig globalChangelogClientConfig,
                                            io.tehuti.metrics.MetricsRepository metricsRepository)

Method Detail

setD2ControllerClient

protected void setD2ControllerClient(D2ControllerClient d2ControllerClient)

setConsumer

protected void setConsumer(PubSubConsumerAdapter consumer)

getChangelogConsumer

public <K,V> VeniceChangelogConsumer<K,V> getChangelogConsumer(java.lang.String storeName)

Default method to create a VeniceChangelogConsumer given a storeName.

getChangelogConsumer

public <K,V> VeniceChangelogConsumer<K,V> getChangelogConsumer(java.lang.String storeName,
                                                                           java.lang.String consumerId)

getChangelogConsumer

public <K,V> VeniceChangelogConsumer<K,V> getChangelogConsumer(java.lang.String storeName,
                                                                           java.lang.String consumerId,
                                                                           java.lang.Class clazz)

Creates a VeniceChangelogConsumer with consumer id. This is used to create multiple consumers so that each consumer can only subscribe to certain partitions. Multiple such consumers can work in parallel.

getBootstrappingChangelogConsumer

public <K,V> BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(java.lang.String storeName)

getBootstrappingChangelogConsumer

public <K,V> BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(java.lang.String storeName,
                                                                                                     java.lang.String consumerId,
                                                                                                     java.lang.Class clazz)

Creates a BootstrappingVeniceChangelogConsumer with consumer id. This is used to create multiple consumers so that each consumer can only subscribe to certain partitions.

getBootstrappingChangelogConsumer

public <K,V> BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(java.lang.String storeName,
                                                                                                     java.lang.String consumerId)

setViewClassGetter

protected void setViewClassGetter(VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter)