Package io.confluent.kafka.schemaregistry.rest

Class SchemaRegistryConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.rest.RestConfig
io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
public class SchemaRegistryConfig extends io.confluent.rest.RestConfig

  • Field Details

  • Constructor Details

    • SchemaRegistryConfig

      public SchemaRegistryConfig(String propsFile) throws io.confluent.rest.RestConfigException
      Throws:
      io.confluent.rest.RestConfigException

    • SchemaRegistryConfig

      public SchemaRegistryConfig(Properties props) throws io.confluent.rest.RestConfigException
      Throws:
      io.confluent.rest.RestConfigException

    • SchemaRegistryConfig

      public SchemaRegistryConfig(org.apache.kafka.common.config.ConfigDef configDef, Properties props) throws io.confluent.rest.RestConfigException
      Throws:
      io.confluent.rest.RestConfigException

  • Method Details

    • baseSchemaRegistryConfigDef

      public static org.apache.kafka.common.config.ConfigDef baseSchemaRegistryConfigDef()

    • originalProperties

      public Properties originalProperties()

    • compatibilityType

      public CompatibilityLevel compatibilityType()

    • checkBootstrapServers

      public void checkBootstrapServers()

    • bootstrapBrokers

      public String bootstrapBrokers()

    • definedResourceExtensionConfigName

      public String definedResourceExtensionConfigName()
      Gets the name of the config that contains resource extension classes, handling deprecated config names. If schema.registry.resource.extension.class has a non-empty value, it will return that; otherwise it returns resource.extension.class.

    • getStaticLocations

      public List<String> getStaticLocations()

    • interInstanceProtocol

      public String interInstanceProtocol()
      Gets the inter.instance.protocol setting, handling the deprecated schema.registry.inter.instance.protocol setting.

    • interInstanceListenerName

      public String interInstanceListenerName()
      Gets the inter.instance.listener.name setting.

    • whitelistHeaders

      public List<String> whitelistHeaders()

    • getOverriddenSslConfigs

      public Map<String,Object> getOverriddenSslConfigs(io.confluent.rest.NamedURI listener)

    • enableAssociations

      public boolean enableAssociations()

    • main

      public static void main(String[] args)