Constant Field Values

io.confluent.*

io.confluent.kafkarest.CeKafkaRestConfig

Modifier and Type	Constant Field	Value
public static final String	PRODUCER_CACHE_IP_AWARE_ENABLE_CONFIG	"kafka.producer.cache.ip.aware.enable"
public static final boolean	PRODUCER_CACHE_IP_AWARE_ENABLE_DEFAULT	false
public static final String	PRODUCER_CACHE_IP_AWARE_ENABLE_DOC	"Enable IP-aware producer caching. When enabled, producer cache keys will include client IP address for proxy protocol connections. "
public static final String	PROXY_PROTOCOL_CLIENT_VERSION	"proxy.protocol.client.version"
public static final String	PROXY_PROTOCOL_CLIENT_VERSION_DOC	"The version of the PROXY Protocol that will be set in admin/produce/consume clients. This mirrors the config client config PROXY_PROTOCOL_CLIENT_VERSION defined in ConfluentConfigs.java."
public static final String	TENANT_LEVEL_RATE_LIMIT_METRICS_ENABLED	"metrics.rate.limit.tenant.level.enabled"
public static final String	USE_PROXY_PROTOCOL_WITH_BROKER	"use.proxy.protocol.with.broker"
public static final boolean	USE_PROXY_PROTOCOL_WITH_BROKER_DEFAULT	false
public static final String	USE_PROXY_PROTOCOL_WITH_BROKER_DOC	"This controls if proxy-protocol is used between REST <-> BROKER. Default is false."

io.confluent.kafkarest.auth.CloudExtensionsAuthFilter

Modifier and Type	Constant Field	Value
public static final String	REQUIRE_SECRETS_STORE_VALIDATION_CONFIG	"secrets.store.validation.required"
public static final String	VALIDATE_CLUSTER_ID_IN_URL_CONFIG	"validate.cluster.id.in.url"

io.confluent.kafkarest.auth.KafkaProducerCacheImpl

Modifier and Type	Constant Field	Value
public static final String	EXCEPTION_CACHE_CAPACITY_CONFIG	"kafka.producer.cache.exception.cache.capacity"
public static final int	EXCEPTION_CACHE_DEFAULT_CAPACITY	200
public static final long	EXCEPTION_CACHE_DEFAULT_VALIDITY_MILLIS	10000L
public static final String	EXCEPTION_CACHE_ENABLE_CONFIG	"kafka.producer.cache.exception.cache.enable"
public static final boolean	EXCEPTION_CACHE_ENABLE_DEFAULT	false
public static final String	EXCEPTION_CACHE_VALIDITY_MILLIS_CONFIG	"kafka.producer.cache.exception.cache.validity.ms"
public static final String	PRODUCER_CACHE_CAPACITY_CONFIG	"kafka.producer.cache.capacity"
public static final int	PRODUCER_CACHE_DEFAULT_CAPACITY	100
public static final long	PRODUCER_CACHE_DEFAULT_VALIDITY_MILLIS	30000L
public static final String	PRODUCER_CACHE_TRACKING_USAGE_REFCOUNT_ENABLE_CONFIG	"kafka.producer.cache.tracking.usage.enable"
public static final String	PRODUCER_CACHE_VALIDITY_MILLIS_CONFIG	"kafka.producer.cache.validity.ms"

io.confluent.kafkarest.backends.kafka.CloudKafkaModule

Modifier and Type	Constant Field	Value
public static final String	KAFKA_PRODUCER_CACHE_ENABLE_CONFIG	"kafka.producer.cache.enable"
public static final String	KAFKA_REST_CONTEXT_PROPERTY_NAME	"io.confluent.kafkarest.backends.kafka.CloudKafkaModule.KafkaRestContext"

io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

Modifier and Type	Constant Field	Value
public static final String	ELEMENT_TYPE	"process"

io.confluent.kafkarest.entities.v3.BalancerData

Modifier and Type	Constant Field	Value
public static final String	ELEMENT_TYPE	"process"

io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

Modifier and Type	Constant Field	Value
public static final String	BAD_REQUEST_ERROR_MSG_ALTER_OFFSETS_TMPL	"Topic-partition %s doesn\'t exist."
public static final String	GROUP_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL	"Group unauthorized to alter offsets for %s"
public static final String	INTERNAL_SERVER_ERROR_MSG_ALTER_OFFSETS_TMPL	"Unexpected server error while altering offsets for %s"
public static final String	INTERNAL_SERVER_ERROR_MSG_LIST_OFFSETS_TMPL	"Unexpected server error while listing offsets for %s"
public static final String	TOPIC_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL	"Topic unauthorized to alter offsets for %s"
public static final String	UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL	"Unauthorized to alter offsets for %s"
public static final String	UNAUTHORIZED_ERROR_MSG_LIST_OFFSETS_TMPL	"Unauthorized to list offsets for %s"

io.confluent.kafkarest.resources.v3.ConsumerGroupOffsetsResource

Modifier and Type	Constant Field	Value
public static final String	ALTER_OFFSETS_INVALID_CONSUMER_GROUP_STATE_ERROR_TMPL	"%s has state %s, alter offsets only allowed in state \'empty\' or \'dead\'."

io.confluent.kafkarest.resources.v3.ShareGroupOffsetsResource

Modifier and Type	Constant Field	Value
public static final String	ALTER_OFFSETS_INVALID_SHARE_GROUP_STATE_ERROR_TMPL	"Share group \'%s\' has active members. Altering offsets is not allowed until the group is empty."

io.confluent.kafkarest.resources.v3.SimpleConsumeAction

Modifier and Type	Constant Field	Value
public static final String	ERROR_MESSAGE_MAX_BYTES_CANNOT_BE_NEGATIVE	"message_max_bytes cannot be negative."
public static final int	MAX_POLL_RECORDS_LIMIT	2000

io.confluent.kafkarest.utils.SimpleConsumeKeyValueDeserializer

Modifier and Type	Constant Field	Value
public static final String	KAFKA_HEADERS_KEY_FOR_KEY_SCHEMA_ID	"__key_schema_id"
public static final String	KAFKA_HEADERS_KEY_FOR_VALUE_SCHEMA_ID	"__value_schema_id"
public static final String	RAW_DATA_PROPERTY	"__raw__"