Package com.linkedin.venice.samza

Class VeniceSystemProducerConfig

java.lang.Object

com.linkedin.venice.samza.VeniceSystemProducerConfig

public class VeniceSystemProducerConfig
extends Object

Configuration options for constructing a VeniceSystemProducer. Use the VeniceSystemProducerConfig.Builder to create instances. Three mutually exclusive connection modes are supported: - ZK-based: set veniceChildD2ZkHost, primaryControllerColoD2ZKHost, and primaryControllerD2ServiceName - D2Client-based: set providedChildColoD2Client, providedPrimaryControllerColoD2Client, and primaryControllerD2ServiceName - Discovery-URL-based: set discoveryUrl

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	VeniceSystemProducerConfig.Builder

Method Summary

Modifier and Type	Method	Description
String	getDiscoveryUrl()
VeniceSystemFactory	getFactory()
Optional<String>	getPartitioners()
String	getPrimaryControllerColoD2ZKHost()
String	getPrimaryControllerD2ServiceName()
com.linkedin.d2.balancer.D2Client	getProvidedChildColoD2Client()
com.linkedin.d2.balancer.D2Client	getProvidedPrimaryControllerColoD2Client()
Version.PushType	getPushType()
String	getRouterUrl()
String	getRunningFabric()
org.apache.samza.config.Config	getSamzaConfig()
String	getSamzaJobId()
Optional<SSLFactory>	getSslFactory()
String	getStoreName()
Time	getTime()
String	getVeniceChildD2ZkHost()
VeniceWriterHook	getWriterHook()
boolean	isVerifyLatestProtocolPresent()
VeniceSystemProducerConfig.Builder	toBuilder()	Returns a new VeniceSystemProducerConfig.Builder pre-populated with all fields from this config instance.

Methods inherited from class java.lang.Object

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

Method Details

getStoreName

public String getStoreName()

getPushType

public Version.PushType getPushType()

getSamzaJobId

public String getSamzaJobId()

getRunningFabric

public String getRunningFabric()

isVerifyLatestProtocolPresent

public boolean isVerifyLatestProtocolPresent()

getVeniceChildD2ZkHost

public String getVeniceChildD2ZkHost()

getPrimaryControllerColoD2ZKHost

public String getPrimaryControllerColoD2ZKHost()

getPrimaryControllerD2ServiceName

public String getPrimaryControllerD2ServiceName()

getProvidedChildColoD2Client

public com.linkedin.d2.balancer.D2Client getProvidedChildColoD2Client()

getProvidedPrimaryControllerColoD2Client

public com.linkedin.d2.balancer.D2Client getProvidedPrimaryControllerColoD2Client()

getDiscoveryUrl

public String getDiscoveryUrl()

getFactory

public VeniceSystemFactory getFactory()

getSslFactory

public Optional<SSLFactory> getSslFactory()

getPartitioners

public Optional<String> getPartitioners()

getTime

public Time getTime()

getWriterHook

public VeniceWriterHook getWriterHook()

getSamzaConfig

public org.apache.samza.config.Config getSamzaConfig()

getRouterUrl

public String getRouterUrl()

toBuilder

public VeniceSystemProducerConfig.Builder toBuilder()

Returns a new VeniceSystemProducerConfig.Builder pre-populated with all fields from this config instance. This is useful when a subclass needs to create a modified copy of an existing config (e.g., to add a writer hook) without manually copying every field.