Package com.linkedin.davinci.consumer

Class ChangelogClientConfig<T extends org.apache.avro.specific.SpecificRecord>

java.lang.Object
com.linkedin.davinci.consumer.ChangelogClientConfig<T>
public class ChangelogClientConfig<T extends org.apache.avro.specific.SpecificRecord> extends Object

  • Constructor Details

    • ChangelogClientConfig

      public ChangelogClientConfig(String storeName)

    • ChangelogClientConfig

      public ChangelogClientConfig()

  • Method Details

    • setStoreName

      public ChangelogClientConfig<T> setStoreName(String storeName)

    • getStoreName

      public String getStoreName()

    • setConsumerProperties

      public ChangelogClientConfig<T> setConsumerProperties(Properties consumerProperties)

    • getConsumerProperties

      public Properties getConsumerProperties()

    • setSchemaReader

      public ChangelogClientConfig<T> setSchemaReader(SchemaReader schemaReader)

    • getSchemaReader

      public SchemaReader getSchemaReader()

    • setViewName

      public ChangelogClientConfig<T> setViewName(String viewName)

    • setConsumerName

      public ChangelogClientConfig<T> setConsumerName(String consumerName)

    • setShouldCompactMessages

      public ChangelogClientConfig<T> setShouldCompactMessages(boolean compactMessages)

    • getViewName

      public String getViewName()

    • getConsumerName

      public String getConsumerName()

    • shouldCompactMessages

      public boolean shouldCompactMessages()

    • setControllerD2ServiceName

      public ChangelogClientConfig<T> setControllerD2ServiceName(String controllerD2ServiceName)

    • getControllerD2ServiceName

      public String getControllerD2ServiceName()

    • setD2ServiceName

      public ChangelogClientConfig<T> setD2ServiceName(String d2ServiceName)

    • getD2ServiceName

      public String getD2ServiceName()

    • setD2ControllerClient

      public ChangelogClientConfig<T> setD2ControllerClient(D2ControllerClient d2ControllerClient)

    • getD2ControllerClient

      public D2ControllerClient getD2ControllerClient()

    • setD2Client

      public ChangelogClientConfig<T> setD2Client(com.linkedin.d2.balancer.D2Client d2Client)

    • getD2Client

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

    • setLocalD2ZkHosts

      public ChangelogClientConfig<T> setLocalD2ZkHosts(String localD2ZkHosts)

    • getLocalD2ZkHosts

      public String getLocalD2ZkHosts()

    • setControllerRequestRetryCount

      public ChangelogClientConfig<T> setControllerRequestRetryCount(int controllerRequestRetryCount)

    • getControllerRequestRetryCount

      public int getControllerRequestRetryCount()

    • getInnerClientConfig

      public ClientConfig<T> getInnerClientConfig()

    • setBootstrapFileSystemPath

      public ChangelogClientConfig<T> setBootstrapFileSystemPath(String bootstrapFileSystemPath)

    • getBootstrapFileSystemPath

      public String getBootstrapFileSystemPath()

    • getVersionSwapDetectionIntervalTimeInSeconds

      public long getVersionSwapDetectionIntervalTimeInSeconds()

    • setVersionSwapDetectionIntervalTimeInSeconds

      public ChangelogClientConfig setVersionSwapDetectionIntervalTimeInSeconds(long intervalTimeInSeconds)

    • getSeekThreadPoolSize

      public int getSeekThreadPoolSize()

    • setSeekThreadPoolSize

      public ChangelogClientConfig setSeekThreadPoolSize(int seekThreadPoolSize)

    • getDatabaseSyncBytesInterval

      public long getDatabaseSyncBytesInterval()
      Gets the databaseSyncBytesInterval.

    • setDatabaseSyncBytesInterval

      public ChangelogClientConfig setDatabaseSyncBytesInterval(long databaseSyncBytesInterval)
      Sets the value for databaseSyncBytesInterval.

    • getRocksDBBlockCacheSizeInBytes

      public long getRocksDBBlockCacheSizeInBytes()

    • setRocksDBBlockCacheSizeInBytes

      public ChangelogClientConfig setRocksDBBlockCacheSizeInBytes(long rocksDBBlockCacheSizeInBytes)

    • setSpecificValue

      public ChangelogClientConfig setSpecificValue(Class<T> specificValue)

    • setShouldSkipFailedToAssembleRecords

      public ChangelogClientConfig setShouldSkipFailedToAssembleRecords(boolean skipFailedToAssembleRecords)

    • shouldSkipFailedToAssembleRecords

      public boolean shouldSkipFailedToAssembleRecords()

    • cloneConfig

      public static <V extends org.apache.avro.specific.SpecificRecord> ChangelogClientConfig<V> cloneConfig(ChangelogClientConfig<V> config)

    • isBeforeImageView

      protected Boolean isBeforeImageView()

    • setIsBeforeImageView

      public ChangelogClientConfig setIsBeforeImageView(Boolean beforeImageView)

    • isExperimentalClientEnabled

      protected Boolean isExperimentalClientEnabled()

    • setIsExperimentalClientEnabled

      public ChangelogClientConfig setIsExperimentalClientEnabled(Boolean experimentalClientEnabled)
      This uses a highly experimental client. It is currently only supported for BootstrappingVeniceChangelogConsumer.

    • isBlobTransferEnabled

      protected Boolean isBlobTransferEnabled()

    • setIsBlobTransferEnabled

      public ChangelogClientConfig setIsBlobTransferEnabled(Boolean blobTransferEnabled)
      This is used by the experimental client to speed up bootstrapping times through blob transfer. In order for this feature to be used, setIsExperimentalClientEnabled(Boolean) must be set to true. It is currently only supported for BootstrappingVeniceChangelogConsumer.

    • getMaxBufferSize

      protected int getMaxBufferSize()

    • setMaxBufferSize

      public ChangelogClientConfig setMaxBufferSize(int maxBufferSize)
      Sets the maximum number of records that can be buffered and returned to the user when calling poll. When the maximum number of records is reached, ingestion will be paused until the buffer is drained. Please note that this is separate from ConfigKeys.SERVER_KAFKA_MAX_POLL_RECORDS. In order for this feature to be used, setIsExperimentalClientEnabled(Boolean) must be set to true. It is currently only supported for BootstrappingVeniceChangelogConsumer.