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

    • RESOURCE_LABEL_PREFIX

      public static final String RESOURCE_LABEL_PREFIX
      See Also:

    • RESOURCE_LABEL_GROUP_ID

      public static final String RESOURCE_LABEL_GROUP_ID
      See Also:

    • RESOURCE_LABEL_CLUSTER_ID

      public static final String RESOURCE_LABEL_CLUSTER_ID
      See Also:

    • RESOURCE_LABEL_TYPE

      public static final String RESOURCE_LABEL_TYPE
      See Also:

    • RESOURCE_LABEL_VERSION

      public static final String RESOURCE_LABEL_VERSION
      See Also:

    • RESOURCE_LABEL_COMMIT_ID

      public static final String RESOURCE_LABEL_COMMIT_ID
      See Also:

    • RESOURCE_CERT_LABEL_TYPE

      public static final String RESOURCE_CERT_LABEL_TYPE
      See Also:

    • RESOURCE_CERT_LABEL_NAME

      public static final String RESOURCE_CERT_LABEL_NAME
      See Also:

    • LISTENER_NAME_PREFIX

      public static final String LISTENER_NAME_PREFIX
      See Also:

    • SCHEMAREGISTRY_GROUP_ID_CONFIG

      public static final String SCHEMAREGISTRY_GROUP_ID_CONFIG
      See Also:

    • KAFKASTORE_SECURITY_PROTOCOL_SSL

      @Deprecated public static final String KAFKASTORE_SECURITY_PROTOCOL_SSL
      Deprecated.
      See Also:

    • KAFKASTORE_SECURITY_PROTOCOL_PLAINTEXT

      @Deprecated public static final String KAFKASTORE_SECURITY_PROTOCOL_PLAINTEXT
      Deprecated.
      See Also:

    • KAFKASTORE_CONNECTION_URL_CONFIG

      @Deprecated public static final String KAFKASTORE_CONNECTION_URL_CONFIG
      Deprecated.
      See Also:

    • KAFKASTORE_BOOTSTRAP_SERVERS_CONFIG

      public static final String KAFKASTORE_BOOTSTRAP_SERVERS_CONFIG
      See Also:

    • KAFKASTORE_GROUP_ID_CONFIG

      public static final String KAFKASTORE_GROUP_ID_CONFIG
      See Also:

    • KAFKASTORE_TOPIC_CONFIG

      public static final String KAFKASTORE_TOPIC_CONFIG
      kafkastore.topic
      See Also:

    • DEFAULT_KAFKASTORE_TOPIC

      public static final String DEFAULT_KAFKASTORE_TOPIC
      See Also:

    • KAFKASTORE_TOPIC_SKIP_VALIDATION_CONFIG

      public static final String KAFKASTORE_TOPIC_SKIP_VALIDATION_CONFIG
      kafkastore.topic.skip.validation
      See Also:

    • DEFAULT_KAFKASTORE_TOPIC_SKIP_VALIDATION

      public static final boolean DEFAULT_KAFKASTORE_TOPIC_SKIP_VALIDATION
      See Also:

    • KAFKASTORE_TOPIC_REPLICATION_FACTOR_CONFIG

      public static final String KAFKASTORE_TOPIC_REPLICATION_FACTOR_CONFIG
      kafkastore.topic.replication.factor
      See Also:

    • DEFAULT_KAFKASTORE_TOPIC_REPLICATION_FACTOR

      public static final int DEFAULT_KAFKASTORE_TOPIC_REPLICATION_FACTOR
      See Also:

    • KAFKASTORE_WRITE_MAX_RETRIES_CONFIG

      public static final String KAFKASTORE_WRITE_MAX_RETRIES_CONFIG
      kafkastore.write.max.retries
      See Also:

    • DEFAULT_KAFKASTORE_WRITE_MAX_RETRIES

      public static final int DEFAULT_KAFKASTORE_WRITE_MAX_RETRIES
      See Also:

    • KAFKASTORE_TIMEOUT_CONFIG

      public static final String KAFKASTORE_TIMEOUT_CONFIG
      kafkastore.timeout.ms
      See Also:

    • KAFKASTORE_CHECKPOINT_DIR_CONFIG

      public static final String KAFKASTORE_CHECKPOINT_DIR_CONFIG
      kafkastore.checkpoint.dir
      See Also:

    • KAFKASTORE_CHECKPOINT_VERSION_CONFIG

      public static final String KAFKASTORE_CHECKPOINT_VERSION_CONFIG
      kafkastore.checkpoint.version
      See Also:

    • KAFKASTORE_INIT_TIMEOUT_CONFIG

      public static final String KAFKASTORE_INIT_TIMEOUT_CONFIG
      kafkastore.init.timeout.ms
      See Also:

    • KAFKASTORE_INIT_WAIT_FOR_READER_CONFIG

      public static final String KAFKASTORE_INIT_WAIT_FOR_READER_CONFIG
      kafkastore.init.wait.for.reader
      See Also:

    • KAFKASTORE_UPDATE_HANDLERS_CONFIG

      public static final String KAFKASTORE_UPDATE_HANDLERS_CONFIG
      kafkastore.update.handler
      See Also:

    • KAFKAGROUP_REBALANCE_TIMEOUT_MS_CONFIG

      public static final String KAFKAGROUP_REBALANCE_TIMEOUT_MS_CONFIG
      kafkagroup.rebalance.timeout.ms
      See Also:

    • KAFKAGROUP_SESSION_TIMEOUT_MS_CONFIG

      public static final String KAFKAGROUP_SESSION_TIMEOUT_MS_CONFIG
      kafkagroup.session.timeout.ms
      See Also:

    • KAFKAGROUP_HEARTBEAT_INTERVAL_MS_CONFIG

      public static final String KAFKAGROUP_HEARTBEAT_INTERVAL_MS_CONFIG
      kafkagroup.heartbeat.interval.ms
      See Also:

    • MASTER_ELIGIBILITY

      @Deprecated public static final String MASTER_ELIGIBILITY
      Deprecated.
      leader.eligibility*
      See Also:

    • LEADER_ELIGIBILITY

      public static final String LEADER_ELIGIBILITY
      See Also:

    • DEFAULT_LEADER_ELIGIBILITY

      public static final boolean DEFAULT_LEADER_ELIGIBILITY
      See Also:

    • LEADER_CONNECT_TIMEOUT_MS

      public static final String LEADER_CONNECT_TIMEOUT_MS
      leader.connect.timeout.ms*
      See Also:

    • DEFAULT_LEADER_CONNECT_TIMEOUT_MS

      public static final int DEFAULT_LEADER_CONNECT_TIMEOUT_MS
      See Also:

    • LEADER_READ_TIMEOUT_MS

      public static final String LEADER_READ_TIMEOUT_MS
      leader.read.timeout.ms*
      See Also:

    • DEFAULT_LEADER_READ_TIMEOUT_MS

      public static final int DEFAULT_LEADER_READ_TIMEOUT_MS
      See Also:

    • LEADER_CONNECT_RETRIES

      public static final String LEADER_CONNECT_RETRIES
      leader.connect.retries*
      See Also:

    • DEFAULT_LEADER_CONNECT_RETRIES

      public static final int DEFAULT_LEADER_CONNECT_RETRIES
      See Also:

    • LEADER_RETRIES_WAIT_MS

      public static final String LEADER_RETRIES_WAIT_MS
      leader.retries.wait.ms*
      See Also:

    • DEFAULT_LEADER_RETRIES_WAIT_MS

      public static final int DEFAULT_LEADER_RETRIES_WAIT_MS
      See Also:

    • LEADER_RETRIES_MAX_WAIT_MS

      public static final String LEADER_RETRIES_MAX_WAIT_MS
      leader.retries.max.wait.ms*
      See Also:

    • DEFAULT_LEADER_RETRIES_MAX_WAIT_MS

      public static final int DEFAULT_LEADER_RETRIES_MAX_WAIT_MS
      See Also:

    • LEADER_ELECTION_DELAY

      public static final String LEADER_ELECTION_DELAY
      leader.election.delay*
      See Also:

    • DEFAULT_LEADER_ELECTION_DELAY

      public static final boolean DEFAULT_LEADER_ELECTION_DELAY
      See Also:

    • LEADER_ELECTION_STICKY

      public static final String LEADER_ELECTION_STICKY
      leader.election.sticky*
      See Also:

    • DEFAULT_LEADER_ELECTION_STICKY

      public static final boolean DEFAULT_LEADER_ELECTION_STICKY
      See Also:

    • ASSOCIATIONS_ENABLE

      public static final String ASSOCIATIONS_ENABLE
      associations.enable*
      See Also:

    • DEFAULT_ASSOCIATIONS_ENABLE

      public static final boolean DEFAULT_ASSOCIATIONS_ENABLE
      See Also:

    • ASSOCIATION_BATCH_MUTATE_LIMITS_ENABLED_CONFIG

      public static final String ASSOCIATION_BATCH_MUTATE_LIMITS_ENABLED_CONFIG
      association.batch.mutate.limits.enabled
      See Also:

    • ASSOCIATION_BATCH_MUTATE_LIMITS_ENABLED_DEFAULT

      public static final boolean ASSOCIATION_BATCH_MUTATE_LIMITS_ENABLED_DEFAULT
      See Also:

    • MAX_ASSOCIATION_NUM_PER_MUTATE_BATCH_CONFIG

      public static final String MAX_ASSOCIATION_NUM_PER_MUTATE_BATCH_CONFIG
      association.batch.mutate.max.association.num.per.batch
      See Also:

    • MAX_ASSOCIATION_NUM_PER_MUTATE_BATCH_DEFAULT

      public static final int MAX_ASSOCIATION_NUM_PER_MUTATE_BATCH_DEFAULT
      See Also:

    • MAX_ASSOCIATION_MUTATE_ENTRY_PAYLOAD_BYTES_CONFIG

      public static final String MAX_ASSOCIATION_MUTATE_ENTRY_PAYLOAD_BYTES_CONFIG
      association.batch.mutate.max.association.entry.payload.bytes
      See Also:

    • MAX_ASSOCIATION_MUTATE_ENTRY_PAYLOAD_BYTES_DEFAULT

      public static final int MAX_ASSOCIATION_MUTATE_ENTRY_PAYLOAD_BYTES_DEFAULT
      See Also:

    • MAX_ASSOCIATION_MUTATE_BATCH_PAYLOAD_BYTES_CONFIG

      public static final String MAX_ASSOCIATION_MUTATE_BATCH_PAYLOAD_BYTES_CONFIG
      association.batch.mutate.max.association.batch.payload.bytes
      See Also:

    • MAX_ASSOCIATION_MUTATE_BATCH_PAYLOAD_BYTES_DEFAULT

      public static final int MAX_ASSOCIATION_MUTATE_BATCH_PAYLOAD_BYTES_DEFAULT
      See Also:

    • ASSOCIATION_BATCH_GET_LIMITS_ENABLED_CONFIG

      public static final String ASSOCIATION_BATCH_GET_LIMITS_ENABLED_CONFIG
      association.batch.get.limits.enabled
      See Also:

    • ASSOCIATION_BATCH_GET_LIMITS_ENABLED_DEFAULT

      public static final boolean ASSOCIATION_BATCH_GET_LIMITS_ENABLED_DEFAULT
      See Also:

    • MAX_ASSOCIATION_NUM_PER_GET_BATCH_CONFIG

      public static final String MAX_ASSOCIATION_NUM_PER_GET_BATCH_CONFIG
      association.batch.get.max.association.num.per.batch
      See Also:

    • MAX_ASSOCIATION_NUM_PER_GET_BATCH_DEFAULT

      public static final int MAX_ASSOCIATION_NUM_PER_GET_BATCH_DEFAULT
      See Also:

    • MODE_MUTABILITY

      public static final String MODE_MUTABILITY
      mode.mutability*
      See Also:

    • DEFAULT_MODE_MUTABILITY

      public static final boolean DEFAULT_MODE_MUTABILITY
      See Also:

    • HOST_NAME_CONFIG

      public static final String HOST_NAME_CONFIG
      host.name
      See Also:

    • HOST_PORT_CONFIG

      public static final String HOST_PORT_CONFIG
      See Also:

    • SCHEMA_PROVIDERS_CONFIG

      public static final String SCHEMA_PROVIDERS_CONFIG
      See Also:

    • COMPATIBILITY_CONFIG

      @Deprecated public static final String COMPATIBILITY_CONFIG
      Deprecated.
      schema.compatibility.level
      See Also:

    • SCHEMA_COMPATIBILITY_CONFIG

      public static final String SCHEMA_COMPATIBILITY_CONFIG
      See Also:

    • SCHEMA_VALIDATE_FIELDS_CONFIG

      public static final String SCHEMA_VALIDATE_FIELDS_CONFIG
      See Also:

    • SCHEMA_VALIDATE_FIELDS_DEFAULT

      public static final boolean SCHEMA_VALIDATE_FIELDS_DEFAULT
      See Also:

    • SCHEMA_VALIDATE_NEW_SCHEMAS_CONFIG

      public static final String SCHEMA_VALIDATE_NEW_SCHEMAS_CONFIG
      See Also:

    • SCHEMA_VALIDATE_NEW_SCHEMAS_DEFAULT

      public static final boolean SCHEMA_VALIDATE_NEW_SCHEMAS_DEFAULT
      See Also:

    • SCHEMA_REJECT_EMPTY_SUBJECT_CONFIG

      public static final String SCHEMA_REJECT_EMPTY_SUBJECT_CONFIG
      See Also:

    • SCHEMA_REJECT_EMPTY_SUBJECT_DEFAULT

      public static final boolean SCHEMA_REJECT_EMPTY_SUBJECT_DEFAULT
      See Also:

    • REFERENCE_VERSIONS_STRICT_CONFIG

      public static final String REFERENCE_VERSIONS_STRICT_CONFIG
      See Also:

    • REFERENCE_VERSIONS_STRICT_DEFAULT

      public static final boolean REFERENCE_VERSIONS_STRICT_DEFAULT
      See Also:

    • SCHEMA_PROVIDERS_JSON_FETCH_REMOTE_REFS_CONFIG

      public static final String SCHEMA_PROVIDERS_JSON_FETCH_REMOTE_REFS_CONFIG
      See Also:

    • SCHEMA_PROVIDERS_JSON_FETCH_REMOTE_REFS_DEFAULT

      public static final boolean SCHEMA_PROVIDERS_JSON_FETCH_REMOTE_REFS_DEFAULT
      See Also:

    • SCHEMA_PROVIDERS_JSON_FETCH_REMOTE_REFS_DOC

      protected static final String SCHEMA_PROVIDERS_JSON_FETCH_REMOTE_REFS_DOC
      See Also:

    • SCHEMA_CACHE_SIZE_CONFIG

      public static final String SCHEMA_CACHE_SIZE_CONFIG
      schema.cache.size
      See Also:

    • SCHEMA_CACHE_SIZE_DEFAULT

      public static final int SCHEMA_CACHE_SIZE_DEFAULT
      See Also:

    • SCHEMA_CACHE_EXPIRY_SECS_CONFIG

      public static final String SCHEMA_CACHE_EXPIRY_SECS_CONFIG
      schema.cache.expiry.secs
      See Also:

    • SCHEMA_CACHE_EXPIRY_SECS_DEFAULT

      public static final int SCHEMA_CACHE_EXPIRY_SECS_DEFAULT
      See Also:

    • SIZE_LIMIT_FILTER_ENABLED_CONFIG

      public static final String SIZE_LIMIT_FILTER_ENABLED_CONFIG
      size.limit.handler.enabled
      See Also:

    • SIZE_LIMIT_FILTER_ENABLED_DEFAULT

      public static final boolean SIZE_LIMIT_FILTER_ENABLED_DEFAULT
      See Also:

    • MAX_REQ_BODY_SIZE_CONFIG

      public static final String MAX_REQ_BODY_SIZE_CONFIG
      max.body.size
      See Also:

    • MAX_REQ_BODY_SIZE_DEFAULT

      public static final int MAX_REQ_BODY_SIZE_DEFAULT
      See Also:

    • SCHEMA_CANONICALIZE_ON_CONSUME_CONFIG

      public static final String SCHEMA_CANONICALIZE_ON_CONSUME_CONFIG
      schema.canonicalize.on.consume
      See Also:

    • SCHEMA_SEARCH_DEFAULT_LIMIT_CONFIG

      public static final String SCHEMA_SEARCH_DEFAULT_LIMIT_CONFIG
      schema.search.default.limit
      See Also:

    • SCHEMA_SEARCH_DEFAULT_LIMIT_DEFAULT

      public static final int SCHEMA_SEARCH_DEFAULT_LIMIT_DEFAULT
      See Also:

    • SCHEMA_SEARCH_MAX_LIMIT_CONFIG

      public static final String SCHEMA_SEARCH_MAX_LIMIT_CONFIG
      schema.search.max.limit
      See Also:

    • SCHEMA_SEARCH_MAX_LIMIT_DEFAULT

      public static final int SCHEMA_SEARCH_MAX_LIMIT_DEFAULT
      See Also:

    • SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_CONFIG

      public static final String SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_CONFIG
      subject.version.search.default.limit
      See Also:

    • SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_DEFAULT

      public static final int SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_DEFAULT
      See Also:

    • SUBJECT_VERSION_SEARCH_MAX_LIMIT_CONFIG

      public static final String SUBJECT_VERSION_SEARCH_MAX_LIMIT_CONFIG
      subject.version.search.max.limit
      See Also:

    • SUBJECT_VERSION_SEARCH_MAX_LIMIT_DEFAULT

      public static final int SUBJECT_VERSION_SEARCH_MAX_LIMIT_DEFAULT
      See Also:

    • CONTEXT_SEARCH_DEFAULT_LIMIT_CONFIG

      public static final String CONTEXT_SEARCH_DEFAULT_LIMIT_CONFIG
      context.search.default.limit
      See Also:

    • CONTEXT_SEARCH_DEFAULT_LIMIT_DEFAULT

      public static final int CONTEXT_SEARCH_DEFAULT_LIMIT_DEFAULT
      See Also:

    • CONTEXT_SEARCH_MAX_LIMIT_CONFIG

      public static final String CONTEXT_SEARCH_MAX_LIMIT_CONFIG
      context.search.max.limit
      See Also:

    • CONTEXT_SEARCH_MAX_LIMIT_DEFAULT

      public static final int CONTEXT_SEARCH_MAX_LIMIT_DEFAULT
      See Also:

    • SUBJECT_SEARCH_DEFAULT_LIMIT_CONFIG

      public static final String SUBJECT_SEARCH_DEFAULT_LIMIT_CONFIG
      subject.search.default.limit
      See Also:

    • SUBJECT_SEARCH_DEFAULT_LIMIT_DEFAULT

      public static final int SUBJECT_SEARCH_DEFAULT_LIMIT_DEFAULT
      See Also:

    • SUBJECT_SEARCH_MAX_LIMIT_CONFIG

      public static final String SUBJECT_SEARCH_MAX_LIMIT_CONFIG
      subject.search.max.limit
      See Also:

    • SUBJECT_SEARCH_MAX_LIMIT_DEFAULT

      public static final int SUBJECT_SEARCH_MAX_LIMIT_DEFAULT
      See Also:

    • METADATA_ENCODER_SECRET_CONFIG

      public static final String METADATA_ENCODER_SECRET_CONFIG
      See Also:

    • METADATA_ENCODER_OLD_SECRET_CONFIG

      public static final String METADATA_ENCODER_OLD_SECRET_CONFIG
      See Also:

    • METADATA_ENCODER_TOPIC_CONFIG

      public static final String METADATA_ENCODER_TOPIC_CONFIG
      See Also:

    • METADATA_ENCODER_TOPIC_DEFAULT

      public static final String METADATA_ENCODER_TOPIC_DEFAULT
      See Also:

    • METADATA_ENCODER_SECRET_STRICT_VALIDATION_CONFIG

      public static final String METADATA_ENCODER_SECRET_STRICT_VALIDATION_CONFIG
      See Also:

    • METADATA_ENCODER_SECRET_STRICT_VALIDATION_DEFAULT

      public static final boolean METADATA_ENCODER_SECRET_STRICT_VALIDATION_DEFAULT
      See Also:

    • ENABLE_STORE_HEALTH_CHECK

      public static final String ENABLE_STORE_HEALTH_CHECK
      See Also:

    • DEFAULT_ENABLE_STORE_HEALTH_CHECK

      public static final boolean DEFAULT_ENABLE_STORE_HEALTH_CHECK
      See Also:

    • KAFKASTORE_SECURITY_PROTOCOL_CONFIG

      public static final String KAFKASTORE_SECURITY_PROTOCOL_CONFIG
      See Also:

    • KAFKASTORE_SSL_TRUSTSTORE_LOCATION_CONFIG

      public static final String KAFKASTORE_SSL_TRUSTSTORE_LOCATION_CONFIG
      See Also:

    • KAFKASTORE_SSL_TRUSTSTORE_PASSWORD_CONFIG

      public static final String KAFKASTORE_SSL_TRUSTSTORE_PASSWORD_CONFIG
      See Also:

    • KAFKASTORE_SSL_KEYSTORE_LOCATION_CONFIG

      public static final String KAFKASTORE_SSL_KEYSTORE_LOCATION_CONFIG
      See Also:

    • KAFKASTORE_SSL_TRUSTSTORE_TYPE_CONFIG

      public static final String KAFKASTORE_SSL_TRUSTSTORE_TYPE_CONFIG
      See Also:

    • KAFKASTORE_SSL_TRUSTMANAGER_ALGORITHM_CONFIG

      public static final String KAFKASTORE_SSL_TRUSTMANAGER_ALGORITHM_CONFIG
      See Also:

    • KAFKASTORE_SSL_KEYSTORE_PASSWORD_CONFIG

      public static final String KAFKASTORE_SSL_KEYSTORE_PASSWORD_CONFIG
      See Also:

    • KAFKASTORE_SSL_KEYSTORE_TYPE_CONFIG

      public static final String KAFKASTORE_SSL_KEYSTORE_TYPE_CONFIG
      See Also:

    • KAFKASTORE_SSL_KEYMANAGER_ALGORITHM_CONFIG

      public static final String KAFKASTORE_SSL_KEYMANAGER_ALGORITHM_CONFIG
      See Also:

    • KAFKASTORE_SSL_KEY_PASSWORD_CONFIG

      public static final String KAFKASTORE_SSL_KEY_PASSWORD_CONFIG
      See Also:

    • KAFKASTORE_SSL_ENABLED_PROTOCOLS_CONFIG

      public static final String KAFKASTORE_SSL_ENABLED_PROTOCOLS_CONFIG
      See Also:

    • KAFKASTORE_SSL_PROTOCOL_CONFIG

      public static final String KAFKASTORE_SSL_PROTOCOL_CONFIG
      See Also:

    • KAFKASTORE_SSL_PROVIDER_CONFIG

      public static final String KAFKASTORE_SSL_PROVIDER_CONFIG
      See Also:

    • KAFKASTORE_SSL_CIPHER_SUITES_CONFIG

      public static final String KAFKASTORE_SSL_CIPHER_SUITES_CONFIG
      See Also:

    • KAFKASTORE_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG

      public static final String KAFKASTORE_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG
      See Also:

    • KAFKASTORE_SASL_KERBEROS_SERVICE_NAME_CONFIG

      public static final String KAFKASTORE_SASL_KERBEROS_SERVICE_NAME_CONFIG
      See Also:

    • KAFKASTORE_SASL_MECHANISM_CONFIG

      public static final String KAFKASTORE_SASL_MECHANISM_CONFIG
      See Also:

    • KAFKASTORE_SASL_KERBEROS_KINIT_CMD_CONFIG

      public static final String KAFKASTORE_SASL_KERBEROS_KINIT_CMD_CONFIG
      See Also:

    • KAFKASTORE_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_CONFIG

      public static final String KAFKASTORE_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_CONFIG
      See Also:

    • KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_JITTER_CONFIG

      public static final String KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_JITTER_CONFIG
      See Also:

    • KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_CONFIG

      public static final String KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_CONFIG
      See Also:

    • SCHEMAREGISTRY_RESOURCE_EXTENSION_CONFIG

      @Deprecated public static final String SCHEMAREGISTRY_RESOURCE_EXTENSION_CONFIG
      Deprecated.
      See Also:

    • INIT_RESOURCE_EXTENSION_CONFIG

      public static final String INIT_RESOURCE_EXTENSION_CONFIG
      See Also:

    • RESOURCE_EXTENSION_CONFIG

      public static final String RESOURCE_EXTENSION_CONFIG
      See Also:

    • ENABLE_FIPS_CONFIG

      public static final String ENABLE_FIPS_CONFIG
      See Also:

    • ENABLE_FIPS_MODE_CONFIG

      public static final String ENABLE_FIPS_MODE_CONFIG
      See Also:

    • ENABLE_FIPS_MODE_CONFIG_DEFAULT

      public static final String ENABLE_FIPS_MODE_CONFIG_DEFAULT
      See Also:

    • RESOURCE_STATIC_LOCATIONS_CONFIG

      public static final String RESOURCE_STATIC_LOCATIONS_CONFIG
      See Also:

    • SCHEMAREGISTRY_INTER_INSTANCE_PROTOCOL_CONFIG

      @Deprecated public static final String SCHEMAREGISTRY_INTER_INSTANCE_PROTOCOL_CONFIG
      Deprecated.
      See Also:

    • INTER_INSTANCE_PROTOCOL_CONFIG

      public static final String INTER_INSTANCE_PROTOCOL_CONFIG
      See Also:

    • INTER_INSTANCE_HEADERS_WHITELIST_CONFIG

      public static final String INTER_INSTANCE_HEADERS_WHITELIST_CONFIG
      See Also:

    • INTER_INSTANCE_LISTENER_NAME_CONFIG

      public static final String INTER_INSTANCE_LISTENER_NAME_CONFIG
      See Also:

    • SCHEMAREGISTRY_GROUP_ID_DOC

      protected static final String SCHEMAREGISTRY_GROUP_ID_DOC
      See Also:

    • KAFKASTORE_CONNECTION_URL_DOC

      protected static final String KAFKASTORE_CONNECTION_URL_DOC
      See Also:

    • KAFKASTORE_BOOTSTRAP_SERVERS_DOC

      protected static final String KAFKASTORE_BOOTSTRAP_SERVERS_DOC
      See Also:

    • KAFKASTORE_GROUP_ID_DOC

      protected static final String KAFKASTORE_GROUP_ID_DOC
      See Also:

    • KAFKASTORE_TOPIC_DOC

      protected static final String KAFKASTORE_TOPIC_DOC
      See Also:

    • KAFKASTORE_TOPIC_SKIP_VALIDATION_DOC

      protected static final String KAFKASTORE_TOPIC_SKIP_VALIDATION_DOC
      See Also:

    • KAFKASTORE_TOPIC_REPLICATION_FACTOR_DOC

      protected static final String KAFKASTORE_TOPIC_REPLICATION_FACTOR_DOC
      See Also:

    • KAFKASTORE_WRITE_RETRIES_DOC

      protected static final String KAFKASTORE_WRITE_RETRIES_DOC
      See Also:

    • KAFKASTORE_INIT_TIMEOUT_DOC

      protected static final String KAFKASTORE_INIT_TIMEOUT_DOC
      See Also:

    • KAFKASTORE_INIT_WAIT_FOR_READER_DOC

      protected static final String KAFKASTORE_INIT_WAIT_FOR_READER_DOC
      See Also:

    • KAFKASTORE_CHECKPOINT_DIR_DOC

      protected static final String KAFKASTORE_CHECKPOINT_DIR_DOC
      See Also:

    • KAFKASTORE_CHECKPOINT_VERSION_DOC

      protected static final String KAFKASTORE_CHECKPOINT_VERSION_DOC
      See Also:

    • KAFKASTORE_TIMEOUT_DOC

      protected static final String KAFKASTORE_TIMEOUT_DOC
      See Also:

    • KAFKASTORE_UPDATE_HANDLERS_DOC

      protected static final String KAFKASTORE_UPDATE_HANDLERS_DOC
      See Also:

    • KAFKAGROUP_REBALANCE_TIMEOUT_DOC

      protected static final String KAFKAGROUP_REBALANCE_TIMEOUT_DOC
      See Also:

    • KAFKAGROUP_SESSION_TIMEOUT_DOC

      protected static final String KAFKAGROUP_SESSION_TIMEOUT_DOC
      See Also:

    • KAFKAGROUP_HEARTBEAT_INTERVAL_DOC

      protected static final String KAFKAGROUP_HEARTBEAT_INTERVAL_DOC
      See Also:

    • HOST_DOC

      protected static final String HOST_DOC
      See Also:

    • HOST_PORT_DOC

      protected static final String HOST_PORT_DOC
      See Also:

    • SCHEMA_PROVIDERS_DOC

      protected static final String SCHEMA_PROVIDERS_DOC
      See Also:

    • COMPATIBILITY_DOC

      protected static final String COMPATIBILITY_DOC
      See Also:

    • VALIDATE_FIELDS_DOC

      protected static final String VALIDATE_FIELDS_DOC
      See Also:

    • VALIDATE_NEW_SCHEMAS_DOC

      protected static final String VALIDATE_NEW_SCHEMAS_DOC
      See Also:

    • REJECT_EMPTY_SUBJECT_DOC

      protected static final String REJECT_EMPTY_SUBJECT_DOC
      See Also:

    • REFERENCE_VERSIONS_STRICT_DOC

      protected static final String REFERENCE_VERSIONS_STRICT_DOC
      See Also:

    • SCHEMA_CACHE_SIZE_DOC

      protected static final String SCHEMA_CACHE_SIZE_DOC
      See Also:

    • SCHEMA_CACHE_EXPIRY_SECS_DOC

      protected static final String SCHEMA_CACHE_EXPIRY_SECS_DOC
      See Also:

    • SIZE_LIMIT_HANDLER_ENABLED_DOC

      protected static final String SIZE_LIMIT_HANDLER_ENABLED_DOC
      See Also:

    • MAX_REQ_BODY_SIZE_DOC

      protected static final String MAX_REQ_BODY_SIZE_DOC
      See Also:

    • SCHEMA_CANONICALIZE_ON_CONSUME_DOC

      protected static final String SCHEMA_CANONICALIZE_ON_CONSUME_DOC
      See Also:

    • SCHEMA_SEARCH_DEFAULT_LIMIT_DOC

      protected static final String SCHEMA_SEARCH_DEFAULT_LIMIT_DOC
      See Also:

    • SCHEMA_SEARCH_MAX_LIMIT_DOC

      protected static final String SCHEMA_SEARCH_MAX_LIMIT_DOC
      See Also:

    • CONTEXT_SEARCH_DEFAULT_LIMIT_DOC

      protected static final String CONTEXT_SEARCH_DEFAULT_LIMIT_DOC
      See Also:

    • CONTEXT_SEARCH_MAX_LIMIT_DOC

      protected static final String CONTEXT_SEARCH_MAX_LIMIT_DOC
      See Also:

    • SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_DOC

      protected static final String SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_DOC
      See Also:

    • SUBJECT_VERSION_SEARCH_MAX_LIMIT_DOC

      protected static final String SUBJECT_VERSION_SEARCH_MAX_LIMIT_DOC
      See Also:

    • SUBJECT_SEARCH_DEFAULT_LIMIT_DOC

      protected static final String SUBJECT_SEARCH_DEFAULT_LIMIT_DOC
      See Also:

    • SUBJECT_SEARCH_MAX_LIMIT_DOC

      protected static final String SUBJECT_SEARCH_MAX_LIMIT_DOC
      See Also:

    • METADATA_ENCODER_SECRET_DOC

      protected static final String METADATA_ENCODER_SECRET_DOC
      See Also:

    • METADATA_ENCODER_OLD_SECRET_DOC

      protected static final String METADATA_ENCODER_OLD_SECRET_DOC
      See Also:

    • METADATA_ENCODER_TOPIC_DOC

      protected static final String METADATA_ENCODER_TOPIC_DOC
      See Also:

    • METADATA_ENCODER_SECRET_STRICT_VALIDATION_DOC

      protected static final String METADATA_ENCODER_SECRET_STRICT_VALIDATION_DOC
      See Also:

    • LEADER_ELIGIBILITY_DOC

      protected static final String LEADER_ELIGIBILITY_DOC
      See Also:

    • LEADER_CONNECT_TIMEOUT_MS_DOC

      protected static final String LEADER_CONNECT_TIMEOUT_MS_DOC
      See Also:

    • LEADER_READ_TIMEOUT_MS_DOC

      protected static final String LEADER_READ_TIMEOUT_MS_DOC
      See Also:

    • LEADER_CONNECT_RETRIES_DOC

      protected static final String LEADER_CONNECT_RETRIES_DOC
      See Also:

    • LEADER_RETRIES_WAIT_MS_DOC

      protected static final String LEADER_RETRIES_WAIT_MS_DOC
      See Also:

    • LEADER_RETRIES_MAX_WAIT_MS_DOC

      protected static final String LEADER_RETRIES_MAX_WAIT_MS_DOC
      See Also:

    • LEADER_ELECTION_DELAY_DOC

      protected static final String LEADER_ELECTION_DELAY_DOC
      See Also:

    • LEADER_ELECTION_STICKY_DOC

      protected static final String LEADER_ELECTION_STICKY_DOC
      See Also:

    • ASSOCIATIONS_ENABLE_DOC

      protected static final String ASSOCIATIONS_ENABLE_DOC
      See Also:

    • ASSOCIATION_BATCH_MUTATE_LIMITS_ENABLED_DOC

      protected static final String ASSOCIATION_BATCH_MUTATE_LIMITS_ENABLED_DOC
      See Also:

    • MAX_ASSOCIATION_NUM_PER_MUTATE_BATCH_DOC

      protected static final String MAX_ASSOCIATION_NUM_PER_MUTATE_BATCH_DOC
      See Also:

    • MAX_ASSOCIATION_MUTATE_ENTRY_PAYLOAD_BYTES_DOC

      protected static final String MAX_ASSOCIATION_MUTATE_ENTRY_PAYLOAD_BYTES_DOC
      See Also:

    • MAX_ASSOCIATION_MUTATE_BATCH_PAYLOAD_BYTES_DOC

      protected static final String MAX_ASSOCIATION_MUTATE_BATCH_PAYLOAD_BYTES_DOC
      See Also:

    • ASSOCIATION_BATCH_GET_LIMITS_ENABLED_DOC

      protected static final String ASSOCIATION_BATCH_GET_LIMITS_ENABLED_DOC
      See Also:

    • MAX_ASSOCIATION_NUM_PER_GET_BATCH_DOC

      protected static final String MAX_ASSOCIATION_NUM_PER_GET_BATCH_DOC
      See Also:

    • MODE_MUTABILITY_DOC

      protected static final String MODE_MUTABILITY_DOC
      See Also:

    • ENABLE_STORE_HEALTH_CHECK_DOC

      protected static final String ENABLE_STORE_HEALTH_CHECK_DOC
      See Also:

    • KAFKASTORE_SECURITY_PROTOCOL_DOC

      protected static final String KAFKASTORE_SECURITY_PROTOCOL_DOC
      See Also:

    • KAFKASTORE_SSL_TRUSTSTORE_LOCATION_DOC

      protected static final String KAFKASTORE_SSL_TRUSTSTORE_LOCATION_DOC
      See Also:

    • KAFKASTORE_SSL_TRUSTSTORE_PASSWORD_DOC

      protected static final String KAFKASTORE_SSL_TRUSTSTORE_PASSWORD_DOC
      See Also:

    • KAFAKSTORE_SSL_TRUSTSTORE_TYPE_DOC

      protected static final String KAFAKSTORE_SSL_TRUSTSTORE_TYPE_DOC
      See Also:

    • KAFKASTORE_SSL_TRUSTMANAGER_ALGORITHM_DOC

      protected static final String KAFKASTORE_SSL_TRUSTMANAGER_ALGORITHM_DOC
      See Also:

    • KAFKASTORE_SSL_KEYSTORE_LOCATION_DOC

      protected static final String KAFKASTORE_SSL_KEYSTORE_LOCATION_DOC
      See Also:

    • KAFKASTORE_SSL_KEYSTORE_PASSWORD_DOC

      protected static final String KAFKASTORE_SSL_KEYSTORE_PASSWORD_DOC
      See Also:

    • KAFAKSTORE_SSL_KEYSTORE_TYPE_DOC

      protected static final String KAFAKSTORE_SSL_KEYSTORE_TYPE_DOC
      See Also:

    • KAFKASTORE_SSL_KEYMANAGER_ALGORITHM_DOC

      protected static final String KAFKASTORE_SSL_KEYMANAGER_ALGORITHM_DOC
      See Also:

    • KAFKASTORE_SSL_KEY_PASSWORD_DOC

      protected static final String KAFKASTORE_SSL_KEY_PASSWORD_DOC
      See Also:

    • KAFAKSTORE_SSL_ENABLED_PROTOCOLS_DOC

      protected static final String KAFAKSTORE_SSL_ENABLED_PROTOCOLS_DOC
      See Also:

    • KAFAKSTORE_SSL_PROTOCOL_DOC

      protected static final String KAFAKSTORE_SSL_PROTOCOL_DOC
      See Also:

    • KAFAKSTORE_SSL_PROVIDER_DOC

      protected static final String KAFAKSTORE_SSL_PROVIDER_DOC
      See Also:

    • KAFKASTORE_SSL_CIPHER_SUITES_DOC

      protected static final String KAFKASTORE_SSL_CIPHER_SUITES_DOC
      See Also:

    • KAFKASTORE_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_DOC

      protected static final String KAFKASTORE_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_DOC
      See Also:

    • KAFKASTORE_SASL_KERBEROS_SERVICE_NAME_DOC

      public static final String KAFKASTORE_SASL_KERBEROS_SERVICE_NAME_DOC
      See Also:

    • KAFKASTORE_SASL_MECHANISM_DOC

      public static final String KAFKASTORE_SASL_MECHANISM_DOC
      See Also:

    • KAFKASTORE_SASL_KERBEROS_KINIT_CMD_DOC

      public static final String KAFKASTORE_SASL_KERBEROS_KINIT_CMD_DOC
      See Also:

    • KAFKASTORE_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC

      public static final String KAFKASTORE_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC
      See Also:

    • KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_JITTER_DOC

      public static final String KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_JITTER_DOC
      See Also:

    • KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC

      public static final String KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC
      See Also:

    • ENABLE_FIPS_DOC

      protected static final String ENABLE_FIPS_DOC
      See Also:

    • ENABLE_FIPS_MODE_DOC

      protected static final String ENABLE_FIPS_MODE_DOC
      See Also:

    • SCHEMAREGISTRY_RESOURCE_EXTENSION_DOC

      protected static final String SCHEMAREGISTRY_RESOURCE_EXTENSION_DOC
      See Also:

    • INIT_RESOURCE_EXTENSION_DOC

      protected static final String INIT_RESOURCE_EXTENSION_DOC
      See Also:

    • RESOURCE_STATIC_LOCATIONS_DOC

      protected static final String RESOURCE_STATIC_LOCATIONS_DOC
      See Also:

    • SCHEMAREGISTRY_INTER_INSTANCE_PROTOCOL_DOC

      protected static final String SCHEMAREGISTRY_INTER_INSTANCE_PROTOCOL_DOC
      See Also:

    • INTER_INSTANCE_HEADERS_WHITELIST_DOC

      protected static final String INTER_INSTANCE_HEADERS_WHITELIST_DOC
      See Also:

    • INTER_INSTANCE_LISTENER_NAME_DOC

      protected static final String INTER_INSTANCE_LISTENER_NAME_DOC
      See Also:

    • HTTPS

      public static final String HTTPS
      See Also:

    • HTTP

      public static final String HTTP
      See Also:

  • 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()

    • associationBatchMutateLimitsEnabled

      public boolean associationBatchMutateLimitsEnabled()

    • maxAssociationNumPerMutateBatch

      public int maxAssociationNumPerMutateBatch()

    • maxAssociationMutateEntryPayloadBytes

      public int maxAssociationMutateEntryPayloadBytes()

    • maxAssociationMutateBatchPayloadBytes

      public int maxAssociationMutateBatchPayloadBytes()

    • associationBatchGetLimitsEnabled

      public boolean associationBatchGetLimitsEnabled()

    • maxAssociationNumPerGetBatch

      public int maxAssociationNumPerGetBatch()

    • main

      public static void main(String[] args)