Package com.linkedin.venice.pulsar.sink

Class VenicePulsarSinkConfig

java.lang.Object
com.linkedin.venice.pulsar.sink.VenicePulsarSinkConfig
All Implemented Interfaces:
Serializable
public class VenicePulsarSinkConfig extends Object implements Serializable
Configuration class for the Sink Connector.
See Also:

  • Constructor Details

    • VenicePulsarSinkConfig

      public VenicePulsarSinkConfig()

  • Method Details

    • load

      public static VenicePulsarSinkConfig load(Map<String,Object> map, org.apache.pulsar.io.core.SinkContext sinkContext) throws IOException
      Throws:
      IOException

    • getVeniceDiscoveryUrl

      public String getVeniceDiscoveryUrl()

    • getVeniceRouterUrl

      public String getVeniceRouterUrl()

    • getKafkaSaslConfig

      public String getKafkaSaslConfig()

    • getKafkaSaslMechanism

      public String getKafkaSaslMechanism()

    • getKafkaSecurityProtocol

      public String getKafkaSecurityProtocol()

    • getStoreName

      public String getStoreName()

    • getFlushIntervalMs

      public long getFlushIntervalMs()

    • getMaxNumberUnflushedRecords

      public int getMaxNumberUnflushedRecords()

    • getWriterConfig

      public Map<String,String> getWriterConfig()

    • setVeniceDiscoveryUrl

      public VenicePulsarSinkConfig setVeniceDiscoveryUrl(String veniceDiscoveryUrl)
      Returns:
      this.

    • setVeniceRouterUrl

      public VenicePulsarSinkConfig setVeniceRouterUrl(String veniceRouterUrl)
      Returns:
      this.

    • setKafkaSaslConfig

      public VenicePulsarSinkConfig setKafkaSaslConfig(String kafkaSaslConfig)
      Returns:
      this.

    • setKafkaSaslMechanism

      public VenicePulsarSinkConfig setKafkaSaslMechanism(String kafkaSaslMechanism)
      Returns:
      this.

    • setKafkaSecurityProtocol

      public VenicePulsarSinkConfig setKafkaSecurityProtocol(String kafkaSecurityProtocol)
      Returns:
      this.

    • setStoreName

      public VenicePulsarSinkConfig setStoreName(String storeName)
      Returns:
      this.

    • setFlushIntervalMs

      public VenicePulsarSinkConfig setFlushIntervalMs(long flushIntervalMs)
      Returns:
      this.

    • setMaxNumberUnflushedRecords

      public VenicePulsarSinkConfig setMaxNumberUnflushedRecords(int maxNumberUnflushedRecords)
      Returns:
      this.

    • setWriterConfig

      public void setWriterConfig(Map<String,String> writerConfig)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object