Package com.linkedin.venice.pulsar.sink

Class VenicePulsarSinkConfig

  • All Implemented Interfaces:
    java.io.Serializable
    public class VenicePulsarSinkConfig
extends java.lang.Object
implements java.io.Serializable
    Configuration class for the Sink Connector.
    See Also:
    Serialized Form

    • Constructor Detail

      • VenicePulsarSinkConfig

        public VenicePulsarSinkConfig()

    • Method Detail

      • load

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

      • getVeniceDiscoveryUrl

        public java.lang.String getVeniceDiscoveryUrl()

      • getVeniceRouterUrl

        public java.lang.String getVeniceRouterUrl()

      • getKafkaSaslConfig

        public java.lang.String getKafkaSaslConfig()

      • getKafkaSaslMechanism

        public java.lang.String getKafkaSaslMechanism()

      • getKafkaSecurityProtocol

        public java.lang.String getKafkaSecurityProtocol()

      • getStoreName

        public java.lang.String getStoreName()

      • getFlushIntervalMs

        public long getFlushIntervalMs()

      • getMaxNumberUnflushedRecords

        public int getMaxNumberUnflushedRecords()

      • getWriterConfig

        public java.util.Map<java.lang.String,​java.lang.String> getWriterConfig()

      • setVeniceDiscoveryUrl

        public VenicePulsarSinkConfig setVeniceDiscoveryUrl​(java.lang.String veniceDiscoveryUrl)
        Returns:
        this.

      • setVeniceRouterUrl

        public VenicePulsarSinkConfig setVeniceRouterUrl​(java.lang.String veniceRouterUrl)
        Returns:
        this.

      • setKafkaSaslConfig

        public VenicePulsarSinkConfig setKafkaSaslConfig​(java.lang.String kafkaSaslConfig)
        Returns:
        this.

      • setKafkaSaslMechanism

        public VenicePulsarSinkConfig setKafkaSaslMechanism​(java.lang.String kafkaSaslMechanism)
        Returns:
        this.

      • setKafkaSecurityProtocol

        public VenicePulsarSinkConfig setKafkaSecurityProtocol​(java.lang.String kafkaSecurityProtocol)
        Returns:
        this.

      • setFlushIntervalMs

        public VenicePulsarSinkConfig setFlushIntervalMs​(long flushIntervalMs)
        Returns:
        this.

      • setMaxNumberUnflushedRecords

        public VenicePulsarSinkConfig setMaxNumberUnflushedRecords​(int maxNumberUnflushedRecords)
        Returns:
        this.

      • setWriterConfig

        public void setWriterConfig​(java.util.Map<java.lang.String,​java.lang.String> writerConfig)

      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object

      • canEqual

        protected boolean canEqual​(java.lang.Object other)

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object