Package com.linkedin.venice.writer

Class VeniceWriterOptions

java.lang.Object
com.linkedin.venice.writer.VeniceWriterOptions
public class VeniceWriterOptions extends Object
VeniceWriterOptions is used to pass arguments to VeniceWriter constructor. Before passing VeniceWriterOptions object to VeniceWriter, VeniceWriterFactory methods use it to set some configs.

  • Method Details

    • getBrokerAddress

      public String getBrokerAddress()

    • getTopicName

      public String getTopicName()

    • getKeySerializer

      public VeniceKafkaSerializer getKeySerializer()

    • getValueSerializer

      public VeniceKafkaSerializer getValueSerializer()

    • getWriteComputeSerializer

      public VeniceKafkaSerializer getWriteComputeSerializer()

    • getPartitioner

      public VenicePartitioner getPartitioner()

    • getTime

      public Time getTime()

    • getPartitionCount

      public Integer getPartitionCount()

    • isChunkingEnabled

      public boolean isChunkingEnabled()

    • isRmdChunkingEnabled

      public boolean isRmdChunkingEnabled()

    • getMaxRecordSizeBytes

      public int getMaxRecordSizeBytes()

    • isProducerCompressionEnabled

      public boolean isProducerCompressionEnabled()

    • getProducerCount

      public int getProducerCount()

    • getProducerThreadCount

      public int getProducerThreadCount()

    • getProducerQueueSize

      public int getProducerQueueSize()

    • toString

      public String toString()
      Overrides:
      toString in class Object