Class CeKafkaRestConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.rest.RestConfig
io.confluent.kafkarest.KafkaRestConfig
io.confluent.kafkarest.CeKafkaRestConfig
public class CeKafkaRestConfig extends io.confluent.kafkarest.KafkaRestConfig

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.confluent.kafkarest.KafkaRestConfig

    io.confluent.kafkarest.KafkaRestConfig.ConfigsWithSafeToString, io.confluent.kafkarest.KafkaRestConfig.PropertiesWithSafeToString

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    PRODUCER_CACHE_IP_AWARE_ENABLE_CONFIG
     
    static final boolean
    PRODUCER_CACHE_IP_AWARE_ENABLE_DEFAULT
     
    static final String
    PRODUCER_CACHE_IP_AWARE_ENABLE_DOC
     
    static final String
    PROXY_PROTOCOL_CLIENT_VERSION
     
    static final String
    PROXY_PROTOCOL_CLIENT_VERSION_DEFAULT
     
    static final String
    PROXY_PROTOCOL_CLIENT_VERSION_DOC
     
    static final String
    TENANT_LEVEL_RATE_LIMIT_METRICS_ENABLED
     
    static final String
    USE_PROXY_PROTOCOL_WITH_BROKER
     
    static final boolean
    USE_PROXY_PROTOCOL_WITH_BROKER_DEFAULT
     
    static final String
    USE_PROXY_PROTOCOL_WITH_BROKER_DOC
     

    Fields inherited from class io.confluent.kafkarest.KafkaRestConfig

    ADVERTISED_LISTENERS_CONFIG, API_ENDPOINTS_ALLOWLIST_CONFIG, API_ENDPOINTS_ALLOWLIST_DOC, API_ENDPOINTS_BLOCKLIST_CONFIG, API_ENDPOINTS_BLOCKLIST_DOC, API_V2_ENABLE_CONFIG, API_V3_ENABLE_CONFIG, BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS_DEFAULT, CONSUMER_INSTANCE_TIMEOUT_MS_CONFIG, CONSUMER_INSTANCE_TIMEOUT_MS_DEFAULT, CONSUMER_ITERATOR_BACKOFF_MS_CONFIG, CONSUMER_ITERATOR_BACKOFF_MS_DEFAULT, CONSUMER_ITERATOR_TIMEOUT_MS_CONFIG, CONSUMER_ITERATOR_TIMEOUT_MS_DEFAULT, CONSUMER_MAX_THREADS_CONFIG, CONSUMER_MAX_THREADS_DEFAULT, CONSUMER_REQUEST_MAX_BYTES_CONFIG, CONSUMER_REQUEST_MAX_BYTES_DEFAULT, CONSUMER_REQUEST_TIMEOUT_MS_CONFIG, CONSUMER_REQUEST_TIMEOUT_MS_DEFAULT, CRN_AUTHORITY_CONFIG, HOST_NAME_CONFIG, ID_CONFIG, ID_DEFAULT, KAFKA_REST_RESOURCE_EXTENSION_CONFIG, KAFKACLIENT_INIT_TIMEOUT_CONFIG, KAFKACLIENT_SASL_KERBEROS_KINIT_CMD_CONFIG, KAFKACLIENT_SASL_KERBEROS_KINIT_CMD_DOC, KAFKACLIENT_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_CONFIG, KAFKACLIENT_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC, KAFKACLIENT_SASL_KERBEROS_SERVICE_NAME_CONFIG, KAFKACLIENT_SASL_KERBEROS_SERVICE_NAME_DOC, KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_JITTER_CONFIG, KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_JITTER_DOC, KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_CONFIG, KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC, KAFKACLIENT_SASL_MECHANISM_CONFIG, KAFKACLIENT_SASL_MECHANISM_DOC, KAFKACLIENT_SECURITY_PROTOCOL_CONFIG, KAFKACLIENT_SSL_CIPHER_SUITES_CONFIG, KAFKACLIENT_SSL_ENABLED_PROTOCOLS_CONFIG, KAFKACLIENT_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, KAFKACLIENT_SSL_KEY_PASSWORD_CONFIG, KAFKACLIENT_SSL_KEYMANAGER_ALGORITHM_CONFIG, KAFKACLIENT_SSL_KEYSTORE_LOCATION_CONFIG, KAFKACLIENT_SSL_KEYSTORE_PASSWORD_CONFIG, KAFKACLIENT_SSL_KEYSTORE_TYPE_CONFIG, KAFKACLIENT_SSL_PROTOCOL_CONFIG, KAFKACLIENT_SSL_PROVIDER_CONFIG, KAFKACLIENT_SSL_TRUSTMANAGER_ALGORITHM_CONFIG, KAFKACLIENT_SSL_TRUSTSTORE_LOCATION_CONFIG, KAFKACLIENT_SSL_TRUSTSTORE_PASSWORD_CONFIG, KAFKACLIENT_SSL_TRUSTSTORE_TYPE_CONFIG, KAFKACLIENT_TIMEOUT_CONFIG, MAX_POLL_RECORDS_CONFIG, MAX_POLL_RECORDS_VALUE, METRICS_JMX_PREFIX_DEFAULT_OVERRIDE, NULL_REQUEST_BODY_ALWAYS_PUBLISH_EMPTY_RECORD_CONFIG, PRODUCE_BATCH_MAXIMUM_ENTRIES, PRODUCE_BATCH_MAXIMUM_ENTRIES_DEFAULT, PRODUCE_BATCH_MAXIMUM_ENTRIES_VALIDATOR, PRODUCE_MAX_BYTES_GLOBAL_PER_SECOND, PRODUCE_MAX_BYTES_GLOBAL_PER_SECOND_DEFAULT, PRODUCE_MAX_BYTES_GLOBAL_PER_SECOND_VALIDATOR, PRODUCE_MAX_BYTES_PER_SECOND, PRODUCE_MAX_BYTES_PER_SECOND_DEFAULT, PRODUCE_MAX_BYTES_PER_SECOND_VALIDATOR, PRODUCE_MAX_REQUESTS_GLOBAL_PER_SECOND, PRODUCE_MAX_REQUESTS_GLOBAL_PER_SECOND_DEFAULT, PRODUCE_MAX_REQUESTS_GLOBAL_PER_SECOND_VALIDATOR, PRODUCE_MAX_REQUESTS_PER_SECOND, PRODUCE_MAX_REQUESTS_PER_SECOND_DEFAULT, PRODUCE_MAX_REQUESTS_PER_SECOND_VALIDATOR, PRODUCE_RATE_LIMIT_CACHE_EXPIRY_MS, PRODUCE_RATE_LIMIT_CACHE_EXPIRY_MS_DEFAULT, PRODUCE_RATE_LIMIT_ENABLED, PRODUCE_RATE_LIMIT_ENABLED_DEFAULT, PRODUCE_REQUEST_SIZE_LIMIT_MAX_BYTES_CONFIG, PRODUCE_REQUEST_SIZE_LIMIT_MAX_BYTES_DEFAULT, PRODUCE_REQUEST_SIZE_LIMIT_MAX_BYTES_VALIDATOR, PRODUCE_RESPONSE_THREAD_POOL_SIZE, PRODUCE_RESPONSE_THREAD_POOL_SIZE_DEFAULT, PRODUCE_RESPONSE_THREAD_POOL_SIZE_VALIDATOR, PRODUCER_THREADS_CONFIG, PRODUCER_THREADS_DEFAULT, PROXY_FETCH_MIN_BYTES_CONFIG, PROXY_FETCH_MIN_BYTES_VALIDATOR, RATE_LIMIT_BACKEND_CONFIG, RATE_LIMIT_COSTS_CONFIG, RATE_LIMIT_DEFAULT_COST_CONFIG, RATE_LIMIT_ENABLE_CONFIG, RATE_LIMIT_PER_CLUSTER_CACHE_EXPIRY_MS, RATE_LIMIT_PER_CLUSTER_CACHE_EXPIRY_MS_DEFAULT, RATE_LIMIT_PER_CLUSTER_PERMITS_PER_SEC_CONFIG, RATE_LIMIT_PERMITS_PER_SEC_CONFIG, RATE_LIMIT_TIMEOUT_MS_CONFIG, SCHEMA_REGISTRY_URL_CONFIG, SIMPLE_CONSUMER_MAX_POOL_SIZE_CONFIG, SIMPLE_CONSUMER_MAX_POOL_SIZE_DEFAULT, SIMPLE_CONSUMER_POOL_TIMEOUT_MS_CONFIG, SIMPLE_CONSUMER_POOL_TIMEOUT_MS_DEFAULT, STREAMING_CONNECTION_MAX_DURATION_GRACE_PERIOD_MS, STREAMING_CONNECTION_MAX_DURATION_MS, TELEMETRY_PREFIX, USE_CUSTOM_REQUEST_LOGGING_CONFIG

    Fields inherited from class io.confluent.rest.RestConfig

    ACCESS_CONTROL_ALLOW_HEADERS, ACCESS_CONTROL_ALLOW_METHODS, ACCESS_CONTROL_ALLOW_ORIGIN_CONFIG, ACCESS_CONTROL_EXPOSE_HEADERS, ACCESS_CONTROL_SKIP_OPTIONS, AUTHENTICATION_METHOD_BASIC, AUTHENTICATION_METHOD_BEARER, AUTHENTICATION_METHOD_CONFIG, AUTHENTICATION_METHOD_DOC, AUTHENTICATION_METHOD_NONE, AUTHENTICATION_METHOD_VALIDATOR, AUTHENTICATION_REALM_CONFIG, AUTHENTICATION_REALM_DOC, AUTHENTICATION_ROLES_CONFIG, AUTHENTICATION_ROLES_DEFAULT, AUTHENTICATION_ROLES_DOC, AUTHENTICATION_SKIP_PATHS, AUTHENTICATION_SKIP_PATHS_DEFAULT, AUTHENTICATION_SKIP_PATHS_DOC, CSRF_PREVENTION_ENABLED, CSRF_PREVENTION_ENABLED_DEFAULT, CSRF_PREVENTION_TOKEN_EXPIRATION_MINUTES, CSRF_PREVENTION_TOKEN_EXPIRATION_MINUTES_DEFAULT, CSRF_PREVENTION_TOKEN_FETCH_ENDPOINT, CSRF_PREVENTION_TOKEN_FETCH_ENDPOINT_DEFAULT, CSRF_PREVENTION_TOKEN_MAX_ENTRIES, CSRF_PREVENTION_TOKEN_MAX_ENTRIES_DEFAULT, DEBUG_CONFIG, DISABLE_RESPONSE_SIZE_METRICS_COLLECTION_CONFIG, ENABLE_GZIP_COMPRESSION_CONFIG, EXPECTED_SNI_HEADERS_CONFIG, HSTS_HEADER_ENABLE_CONFIG, HSTS_HEADER_ENABLE_DEFAULT, HTTP2_ENABLED_CONFIG, IDLE_TIMEOUT_MS_CONFIG, IDLE_TIMEOUT_MS_DEFAULT, IDLE_TIMEOUT_MS_DOC, JETTY_LEGACY_URI_COMPLIANCE, JETTY_LEGACY_URI_COMPLIANCE_DEFAULT, JETTY_LEGACY_URI_COMPLIANCE_DOC, LISTENER_PROTOCOL_MAP_CONFIG, LISTENERS_CONFIG, METRICS_GLOBAL_STATS_REQUEST_TAGS_ENABLE_CONFIG, METRICS_JMX_PREFIX_CONFIG, METRICS_LATENCY_SLA_MS_CONFIG, METRICS_LATENCY_SLO_MS_CONFIG, METRICS_LATENCY_SLO_SLA_ENABLE_CONFIG, METRICS_NUM_SAMPLES_CONFIG, METRICS_REPORTER_CLASSES_CONFIG, METRICS_REPORTER_CONFIG_PREFIX, METRICS_SAMPLE_WINDOW_MS_CONFIG, METRICS_TAGS_CONFIG, NOSNIFF_PROTECTION_ENABLED, NOSNIFF_PROTECTION_ENABLED_DEFAULT, PERCENTILE_MAX_LATENCY_MS_CONFIG, PORT_CONFIG, PREFIX_SNI_CHECK_ENABLED_CONFIG, PREFIX_SNI_PREFIX_CONFIG, PROXY_PROTOCOL_ENABLED_CONFIG, REJECT_OPTIONS_REQUEST, REQUEST_LOGGER_NAME_CONFIG, REQUEST_QUEUE_CAPACITY_CONFIG, REQUEST_QUEUE_CAPACITY_DEFAULT, REQUEST_QUEUE_CAPACITY_DOC, REQUEST_QUEUE_CAPACITY_GROWBY_CONFIG, REQUEST_QUEUE_CAPACITY_GROWBY_DEFAULT, REQUEST_QUEUE_CAPACITY_GROWBY_DOC, REQUEST_QUEUE_CAPACITY_INITIAL_CONFIG, REQUEST_QUEUE_CAPACITY_INITIAL_DEFAULT, REQUEST_QUEUE_CAPACITY_INITIAL_DOC, RESOURCE_EXTENSION_CLASSES_CONFIG, RESPONSE_HTTP_HEADERS_CONFIG, RESPONSE_HTTP_HEADERS_DEFAULT, RESPONSE_HTTP_HEADERS_DOC, RESPONSE_MEDIATYPE_DEFAULT_CONFIG, RESPONSE_MEDIATYPE_PREFERRED_CONFIG, REST_SERVLET_INITIALIZERS_CLASSES_CONFIG, REST_SERVLET_INITIALIZERS_CLASSES_DOC, RETURN_429_INSTEAD_OF_500_FOR_JETTY_RESPONSE_ERRORS_CONFIG, SHUTDOWN_GRACEFUL_MS_CONFIG, SNI_CHECK_ENABLED_CONFIG, SNI_HOST_CHECK_ENABLED_CONFIG, SSL_CIPHER_SUITES_CONFIG, SSL_CLIENT_AUTH_CONFIG, SSL_CLIENT_AUTHENTICATION_CONFIG, SSL_CLIENT_AUTHENTICATION_NONE, SSL_CLIENT_AUTHENTICATION_REQUESTED, SSL_CLIENT_AUTHENTICATION_REQUIRED, SSL_CLIENT_AUTHENTICATION_VALIDATOR, SSL_ENABLED_PROTOCOLS_CONFIG, SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, SSL_KEY_PASSWORD_CONFIG, SSL_KEYMANAGER_ALGORITHM_CONFIG, SSL_KEYSTORE_LOCATION_CONFIG, SSL_KEYSTORE_PASSWORD_CONFIG, SSL_KEYSTORE_RELOAD_CONFIG, SSL_KEYSTORE_TYPE_CONFIG, SSL_KEYSTORE_WATCH_LOCATION_CONFIG, SSL_PROTOCOL_CONFIG, SSL_PROVIDER_CONFIG, SSL_SPIRE_ENABLED_CONFIG, SSL_SPIRE_ENABLED_DOC, SSL_TRUSTMANAGER_ALGORITHM_CONFIG, SSL_TRUSTSTORE_LOCATION_CONFIG, SSL_TRUSTSTORE_PASSWORD_CONFIG, SSL_TRUSTSTORE_TYPE_CONFIG, SUPPRESS_STACK_TRACE_IN_RESPONSE, THREAD_POOL_MAX_CONFIG, THREAD_POOL_MAX_DEFAULT, THREAD_POOL_MAX_DOC, THREAD_POOL_MIN_CONFIG, THREAD_POOL_MIN_DEFAULT, THREAD_POOL_MIN_DOC, WEBSOCKET_PATH_PREFIX_CONFIG, WEBSOCKET_PATH_PREFIX_DOC, WEBSOCKET_SERVLET_INITIALIZERS_CLASSES_CONFIG, WEBSOCKET_SERVLET_INITIALIZERS_CLASSES_DOC

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

    AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

  • Constructor Summary

    Constructors
    Constructor
    Description
    CeKafkaRestConfig(Properties props)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static boolean
    getBooleanOrDefault(io.confluent.kafkarest.KafkaRestConfig config, String configKey, boolean defaultValue)
     
    static int
    getIntOrDefault(io.confluent.kafkarest.KafkaRestConfig config, String key, int defaultValue)
     
    static long
    getLongOrDefault(io.confluent.kafkarest.KafkaRestConfig config, String key, long defaultValue)
     

    Methods inherited from class io.confluent.kafkarest.KafkaRestConfig

    addTelemetryReporterProperties, getAdminProperties, getAvroSerializerConfigs, getConsumerProperties, getJsonschemaSerializerConfigs, getJsonSerializerConfigs, getMetrics, getMetricsContext, getOriginalProperties, getProducerConfigs, getProduceRequestSizeLimitMaxBytesConfig, getProducerProperties, getProtobufSerializerConfigs, getRateLimitBackend, getRateLimitCosts, getRateLimitDefaultCost, getRateLimitPermitsPerSec, getRateLimitTimeout, getSchemaRegistryConfigs, getStreamingConnectionMaxDuration, getStreamingConnectionMaxDurationGracePeriod, isNullRequestBodyAlwaysPublishEmptyRecordEnabled, isRateLimitEnabled, isSchemaRegistryEnabled, isV2ApiEnabled, isV3ApiEnabled, setMetrics

    Methods inherited from class io.confluent.rest.RestConfig

    baseConfigDef, baseConfigDef, baseConfigDef, baseConfigDef, getBaseSslConfig, getBooleanOrDefault, getBooleanOrDefault, getConnectorConnectionLimit, getDisableResponseSizeMetricsCollection, getDoLog, getDosFilterDelayMs, getDosFilterInsertHeaders, getDosFilterIpWhitelist, getDosFilterManagedAttr, getDosFilterMaxIdleTrackerMs, getDosFilterMaxRequestMs, getDosFilterMaxRequestsGlobalPerSec, getDosFilterMaxRequestsPerConnectionPerSec, getDosFilterMaxWaitMs, getDosFilterTenantMaxRequestsPerSec, getDosFilterThrottledRequests, getDosFilterThrottleMs, getExpectedSniHeaders, getInstanceConfig, getListenerProtocolMap, getListeners, getMap, getNetworkTrafficRateLimitBackend, getNetworkTrafficRateLimitBytesPerSec, getNetworkTrafficRateLimitEnable, getPrefixSniCheckEnable, getPrefixSniPrefix, getReturn429InsteadOf500ForJettyResponseErrors, getServerConnectionLimit, getSniCheckEnable, getSniHostCheckEnable, getSslConfigs, getSuppressStackTraceInResponse, getTime, isDosFilterEnabled, isDosFilterTenantDryRunEnabled, isDosFilterTenantEnabled, metricsReporterConfig, validateHttpResponseHeaderConfig

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

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

    Methods inherited from class java.lang.Object

    getClass, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • PROXY_PROTOCOL_CLIENT_VERSION

      public static final String PROXY_PROTOCOL_CLIENT_VERSION
      See Also:

    • PROXY_PROTOCOL_CLIENT_VERSION_DOC

      public static final String PROXY_PROTOCOL_CLIENT_VERSION_DOC
      See Also:

    • PROXY_PROTOCOL_CLIENT_VERSION_DEFAULT

      public static final String PROXY_PROTOCOL_CLIENT_VERSION_DEFAULT

    • USE_PROXY_PROTOCOL_WITH_BROKER

      public static final String USE_PROXY_PROTOCOL_WITH_BROKER
      See Also:

    • USE_PROXY_PROTOCOL_WITH_BROKER_DOC

      public static final String USE_PROXY_PROTOCOL_WITH_BROKER_DOC
      See Also:

    • USE_PROXY_PROTOCOL_WITH_BROKER_DEFAULT

      public static final boolean USE_PROXY_PROTOCOL_WITH_BROKER_DEFAULT
      See Also:

    • PRODUCER_CACHE_IP_AWARE_ENABLE_CONFIG

      public static final String PRODUCER_CACHE_IP_AWARE_ENABLE_CONFIG
      See Also:

    • PRODUCER_CACHE_IP_AWARE_ENABLE_DOC

      public static final String PRODUCER_CACHE_IP_AWARE_ENABLE_DOC
      See Also:

    • PRODUCER_CACHE_IP_AWARE_ENABLE_DEFAULT

      public static final boolean PRODUCER_CACHE_IP_AWARE_ENABLE_DEFAULT
      See Also:

    • TENANT_LEVEL_RATE_LIMIT_METRICS_ENABLED

      public static final String TENANT_LEVEL_RATE_LIMIT_METRICS_ENABLED
      See Also:

  • Constructor Details

    • CeKafkaRestConfig

      public CeKafkaRestConfig(Properties props)

  • Method Details

    • getIntOrDefault

      public static int getIntOrDefault(io.confluent.kafkarest.KafkaRestConfig config, String key, int defaultValue)

    • getLongOrDefault

      public static long getLongOrDefault(io.confluent.kafkarest.KafkaRestConfig config, String key, long defaultValue)

    • getBooleanOrDefault

      public static boolean getBooleanOrDefault(io.confluent.kafkarest.KafkaRestConfig config, String configKey, boolean defaultValue)