Package io.aiven.kafka.connect.common.config

Class CommonConfigFragment

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.aiven.kafka.connect.common.config.CommonConfigFragment
public abstract class CommonConfigFragment extends org.apache.kafka.common.config.AbstractConfig

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected static final String
    GROUP_COMPRESSION
     
    protected static final String
    GROUP_FORMAT
     
    static final String
    KAFKA_RETRY_BACKOFF_MS_CONFIG
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CommonConfigFragment(org.apache.kafka.common.config.ConfigDef definition, Map<?,?> originals)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static void
    addKafkaBackoffPolicy(org.apache.kafka.common.config.ConfigDef configDef)
     
    Long
    getKafkaRetryBackoffMs()
     

    Methods inherited from class org.apache.kafka.common.config.AbstractConfig

    equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • CommonConfigFragment

      public CommonConfigFragment(org.apache.kafka.common.config.ConfigDef definition, Map<?,?> originals)

  • Method Details

    • addKafkaBackoffPolicy

      public static void addKafkaBackoffPolicy(org.apache.kafka.common.config.ConfigDef configDef)

    • getKafkaRetryBackoffMs

      public Long getKafkaRetryBackoffMs()