Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BOOTSTRAP_SERVERS_CONFIG |
"confluent.metrics.reporter.bootstrap.servers" |
public static final String |
BOOTSTRAP_SERVERS_DOC |
"Bootstrap servers for the Kafka cluster metrics will be published to. The metrics cluster may be different from the cluster(s) whose metrics are being collected. Several production Kafka clusters can publish to a single metrics cluster, for example." |
public static final int |
DEFAULT_MIN_ISR |
1 |
public static final String |
DEFAULT_TOPIC_CONFIG |
"_confluent-metrics" |
public static final boolean |
DEFAULT_TOPIC_CREATE_CONFIG |
true |
public static final int |
DEFAULT_TOPIC_MAX_MESSAGE_BYTES_CONFIG |
10485760 |
public static final int |
DEFAULT_TOPIC_PARTITIONS_CONFIG |
12 |
public static final int |
DEFAULT_TOPIC_REPLICAS_CONFIG |
3 |
public static final long |
DEFAULT_TOPIC_RETENTION_BYTES_CONFIG |
-1L |
public static final long |
DEFAULT_VOLUME_METRICS_REFRESH_PERIOD |
15000L |
public static final String |
METRICS_INCLUDE_CONFIG |
"confluent.metrics.reporter.include" |
public static final String |
METRICS_INCLUDE_CONFIG_ALIAS |
"confluent.metrics.reporter.whitelist" |
public static final String |
METRICS_INCLUDE_DOC |
"Regex matching the yammer metric mbean name or Kafka metric name to be published to the metrics topic.\n\nBy default this includes all the metrics required by Confluent Control Center and Confluent Auto Data Balancer. This should typically never be modified unless requested by Confluent." |
public static final String |
METRICS_REPORTER_PREFIX |
"confluent.metrics.reporter." |
public static final String |
PUBLISH_PERIOD_CONFIG |
"confluent.metrics.reporter.publish.ms" |
public static final String |
PUBLISH_PERIOD_DOC |
"The metrics reporter will publish new metrics to the metrics topic in intervals defined by this setting. This means that control center system health data lags by this duration, or that rebalancer may compute a plan based on broker data that is stale by this duration. The default is a reasonable value for production environments and it typically does not need to be changed." |
public static final String |
TOPIC_CONFIG |
"confluent.metrics.reporter.topic" |
public static final String |
TOPIC_CREATE_CONFIG |
"confluent.metrics.reporter.topic.create" |
public static final String |
TOPIC_CREATE_DOC |
"Create the metrics topic if it does not exist." |
public static final String |
TOPIC_DOC |
"Topic on which metrics data will be written." |
public static final String |
TOPIC_MAX_MESSAGE_BYTES_CONFIG |
"confluent.metrics.reporter.topic.max.message.bytes" |
public static final String |
TOPIC_MAX_MESSAGE_BYTES_DOC |
"Maximum message size for the metrics topic." |
public static final String |
TOPIC_PARTITIONS_CONFIG |
"confluent.metrics.reporter.topic.partitions" |
public static final String |
TOPIC_PARTITIONS_DOC |
"Number of partitions in the metrics topic." |
public static final String |
TOPIC_REPLICAS_CONFIG |
"confluent.metrics.reporter.topic.replicas" |
public static final String |
TOPIC_REPLICAS_DOC |
"Number of replicas in the metric topic. It must not be higher than the number of brokers in the Kafka cluster." |
public static final String |
TOPIC_RETENTION_BYTES_CONFIG |
"confluent.metrics.reporter.topic.retention.bytes" |
public static final String |
TOPIC_RETENTION_BYTES_DOC |
"Retention bytes for the metrics topic." |
public static final String |
TOPIC_RETENTION_MS_CONFIG |
"confluent.metrics.reporter.topic.retention.ms" |
public static final String |
TOPIC_RETENTION_MS_DOC |
"Retention time for the metrics topic." |
public static final String |
TOPIC_ROLL_MS_CONFIG |
"confluent.metrics.reporter.topic.roll.ms" |
public static final String |
TOPIC_ROLL_MS_DOC |
"Log rolling time for the metrics topic." |
public static final String |
VOLUME_METRICS_REFRESH_PERIOD_DOC |
"The minimum interval at which to fetch new volume metrics." |
public static final String |
VOLUME_METRICS_REFRESH_PERIOD_MS |
"confluent.metrics.reporter.volume.metrics.refresh.ms" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EMPTY_STRING |
"" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLUSTER_ID_CONFIG |
"confluent.telemetry.cluster.id" |
public static final String |
CLUSTER_ID_DOC |
"The ID of the physical cluster the Telemetry Reporter is configured for" |
public static final String |
COLLECT_INTERVAL_CONFIG |
"confluent.telemetry.metrics.collector.interval.ms" |
public static final String |
COLLECT_INTERVAL_DOC |
"The metrics reporter will collect new metrics from the system in intervals defined by this setting. This means that control center system health data lags by this duration, or that rebalancer may compute a plan based on broker data that is stale by this duration. The default is a reasonable value for production environments and it typically does not need to be changed." |
public static final String |
CONFIG_EVENTS_ENABLE_CONFIG |
"confluent.telemetry.events.enable" |
public static final String |
CONFIG_EVENTS_ENABLE_DOC |
"Enable config events collection.Enabled by default for v7.0." |
public static final String |
CONFIG_EVENTS_INCLUDE_CONFIG |
"confluent.telemetry.events.collector.include" |
public static final String |
CONFIG_EVENTS_INCLUDE_DOC |
"Regex matching the config names to be published to telemetry collector.This should typically never be modified unless requested by Confluent." |
public static final String |
DEBUG_ENABLED |
"confluent.telemetry.debug.enabled" |
public static final String |
DEBUG_ENABLED_DOC |
"Enable debug metadata for metrics collection" |
public static final boolean |
DEFAULT_DEBUG_ENABLED |
false |
public static final String |
DEFAULT_NAMED_FILTER_NAME |
"_default" |
public static final String |
DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX |
"io.confluent.system/.*(process_cpu_load|max_file_descriptor_count|open_file_descriptor_count|system_cpu_load|system_load_average|free_physical_memory_size|total_physical_memory_size|disk_total_bytes|disk_usable_bytes|jvm/mem|jvm/gc)" |
public static final String |
EXPORTER_CONFLUENT_NAME |
"_confluent" |
public static final String |
EXPORTER_LOCAL_NAME |
"_local" |
public static final String |
METRICS_INCLUDE_CONFIG |
"confluent.telemetry.metrics.collector.include" |
public static final String |
METRICS_INCLUDE_CONFIG_ALIAS |
"confluent.telemetry.metrics.collector.whitelist" |
public static final String |
METRICS_INCLUDE_DOC |
"Regex matching the converted (snake_case) metric name to be published to the metrics topic.\n\nBy default this includes all the metrics required by Proactive Support and Self-balancing Clusters. This should typically never be modified unless requested by Confluent." |
public static final String |
PREFIX |
"confluent.telemetry." |
public static final String |
PREFIX_EXPORTER |
"confluent.telemetry.exporter." |
public static final String |
PREFIX_LABELS |
"confluent.telemetry.labels." |
public static final String |
PREFIX_METRICS_COLLECTOR |
"confluent.telemetry.metrics.collector." |
public static final String |
PREFIX_REMOTE_CONFIG |
"confluent.telemetry.remoteconfig." |
public static final String |
REMOTE_CONFIG_CONFLUENT |
"_confluent." |
public static final String |
SLO_COLLECTOR_DOC |
"Enable SLO metric collector" |
public static final String |
SLO_COLLECTOR_ENABLED |
"confluent.telemetry.metrics.collector.slo.enabled" |
public static final String |
TELEMETRY_API_KEY |
"confluent.telemetry.api.key" |
public static final String |
TELEMETRY_API_KEY_DOC |
"The API key used to authenticate HTTP requests with the Confluent telemetry server" |
public static final String |
TELEMETRY_API_SECRET |
"confluent.telemetry.api.secret" |
public static final String |
TELEMETRY_API_SECRET_DOC |
"The API secret used to authenticate HTTP requests with the Confluent Telemetry server" |
public static final String |
TELEMETRY_ENABLED_CONFIG |
"confluent.telemetry.enabled" |
public static final boolean |
TELEMETRY_ENABLED_DEFAULT |
false |
public static final String |
TELEMETRY_ENABLED_DOC |
"True if telemetry data can to be reported to Confluent Cloud" |
public static final String |
TELEMETRY_PROXY_PASSWORD |
"confluent.telemetry.proxy.password" |
public static final String |
TELEMETRY_PROXY_PASSWORD_DOC |
"The password credential for the forward HTTP proxy to send Telemetry data to Confluent Cloud" |
public static final String |
TELEMETRY_PROXY_URL |
"confluent.telemetry.proxy.url" |
public static final String |
TELEMETRY_PROXY_URL_DOC |
"The URL for an explicit (i.e. not transparent) forward HTTP proxy to send Telemetry data to Confluent Cloud" |
public static final String |
TELEMETRY_PROXY_USERNAME |
"confluent.telemetry.proxy.username" |
public static final String |
TELEMETRY_PROXY_USERNAME_DOC |
"The username credential for the forward HTTP proxy to send Telemetry data to Confluent Cloud" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY_HOSTNAME |
"host.hostname" |
public static final String |
NAMESPACE |
"host" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY_VERSION |
"java.version" |
public static final String |
NAMESPACE |
"java" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MATCHER_CACHE_MAX_SIZE |
5000L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KAFKA_METRICS_LIB |
"kafka" |
public static final String |
YAMMER_METRICS_LIB |
"yammer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SYSTEM_DOMAIN |
"io.confluent.system" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LABEL_LIBRARY |
"library" |
public static final String |
LABEL_ORIGINAL |
"metric_name_original" |
public static final String |
LIBRARY_NONE |
"none" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
VOLUME_LABEL |
"volume" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_VOLUME_METRICS_UPDATE_PERIOD |
15000L |
public static final String |
PREFIX |
"confluent.telemetry.metrics.collector.volume." |
public static final String |
VOLUME_METRICS_UPDATE_PERIOD_DOC |
"The minimum interval at which to fetch new volume metrics." |
public static final String |
VOLUME_METRICS_UPDATE_PERIOD_MS |
"confluent.telemetry.metrics.collector.volume.update.ms" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final boolean |
DEFAULT_ENABLED |
false |
public static final String |
ENABLED_CONFIG |
"enabled" |
public static final String |
ENABLED_CONFIG_DOC |
"Boolean value. True if Telemetry Reportershould be remote configurable, false otherwise." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PATH_CONFIG |
"path" |
public static final String |
PATH_DOC |
"Path to the configuration file" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
V1_CONFIGURATION_ENDPOINT |
"/v1/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
REFRESH_INTERVAL_MS_CONFIG |
"refresh.interval.ms" |
public static final String |
REFRESH_INTERVAL_MS_DOC |
"The configured remote configuration source will poll its source for a remote configuration for the Telemetry Reporter in intervals defined by this setting. The default is a reasonable value for production environments and it typically does not need to be changed." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONFIG_MAP_NAME_CONFIG |
"configmap.name" |
public static final String |
CONFIG_MAP_NAME_DOC |
"The name of the Kubernetes ConfigMap to watch for changes to remotely configure if the override cluster named ConfigMap is not present" |
public static final String |
DEFAULT_NAMESPACE |
"telemetry-config" |
public static final String |
NAMESPACE_CONFIG |
"namespace" |
public static final String |
NAMESPACE_DOC |
"The configured KubernetesConfigMapRemoteConfiguration will watch for ConfigMap changes in this configured namespace" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENABLED_CONFIG |
"enabled" |
public static final String |
ENABLED_CONFIG_DOC |
"Boolean value. True if exporter should be enabled, false otherwise. This is a mandatory field that has to be set for every exporter." |
public static final String |
EVENTS_ENABLED_CONFIG |
"events.enabled" |
public static final boolean |
EVENTS_ENABLED_CONFIG_DEFAULT |
true |
public static final String |
EVENTS_ENABLED_CONFIG_DOC |
"Boolean value. True if telemetry events should be reported." |
public static final String |
METRICS_ENABLED_CONFIG |
"metrics.enabled" |
public static final boolean |
METRICS_ENABLED_CONFIG_DEFAULT |
true |
public static final String |
METRICS_ENABLED_CONFIG_DOC |
"Boolean value. True if telemetry metrics should be reported." |
public static final String |
METRICS_INCLUDE_CONFIG |
"metrics.include" |
public static final String |
METRICS_INCLUDE_CONFIG_DOC |
"Regex matching the converted (snake_case) metric name to be published from this particular exporter.\n\nBy default this includes all the metrics required by Proactive Support and Self-balancing Clusters. This should typically never be modified unless requested by Confluent." |
public static final String |
REMOTE_CONFIGURABLE_CONFIG |
"remote.configurable" |
public static final boolean |
REMOTE_CONFIGURABLE_CONFIG_DEFAULT |
false |
public static final String |
REMOTE_CONFIGURABLE_CONFIG_DOC |
"Boolean value. True if the exporter should be remotely configurable." |
public static final String |
TYPE_CONFIG |
"type" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SELF_METRICS_GROUP |
"HttpExporter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
API_KEY |
"api.key" |
public static final String |
API_KEY_DOC |
"The API key used to authenticate the requests made by HttpExporter" |
public static final String |
API_SECRET |
"api.secret" |
public static final String |
API_SECRET_DOC |
"The API secret used to authenticate requests made by HttpExporter" |
public static final String |
BUFFER_MAX_BATCH_DURATION_MS |
"buffer.batch.duration.max.ms" |
public static final String |
BUFFER_MAX_BATCH_DURATION_MS_DOC |
"The maximum duration (in millis) to buffer items before sending them upstream" |
public static final String |
BUFFER_MAX_BATCH_SIZE |
"buffer.batch.items.max" |
public static final String |
BUFFER_MAX_BATCH_SIZE_DOC |
"The maximum number of items to buffer into a batch before sending them upstream" |
public static final String |
BUFFER_MAX_INFLIGHT_SUBMISSIONS |
"buffer.inflight.submissions.max" |
public static final String |
BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC |
"The maximum number of in-flight calls to the HTTP service" |
public static final String |
BUFFER_MAX_PENDING_BATCHES |
"buffer.pending.batches.max" |
public static final String |
BUFFER_MAX_PENDING_BATCHES_DOC |
"The maximum number of pending batches. If more than this number of batches are pending(i.e. there is backpressure) then the oldest batches will be dropped." |
public static final String |
CLIENT_BASE_URL |
"client.base.url" |
public static final String |
CLIENT_BASE_URL_DOC |
"The base URL for the telemetry receiver (i.e. https://host:port)" |
public static final String |
CLIENT_COMPRESSION |
"client.compression" |
public static final String |
CLIENT_COMPRESSION_DOC |
"HTTP Compression algorithm to use. Either gzip, lz4, or zstd." |
public static final String |
CLIENT_CONNECT_TIMEOUT_MS |
"client.connect.timeout.ms" |
public static final String |
CLIENT_CONNECT_TIMEOUT_MS_DOC |
"The connect timeout in milliseconds" |
public static final String |
CLIENT_CONTENT_TYPE |
"client.contentType" |
public static final String |
CLIENT_CONTENT_TYPE_DOC |
"HTTP Content-Type header." |
public static final String |
CLIENT_MAX_ATTEMPTS |
"client.attempts.max" |
public static final String |
CLIENT_MAX_ATTEMPTS_DOC |
"The maximum number of delivery attempts" |
public static final String |
CLIENT_METRICS_PATH |
"client.metrics.path.override" |
public static final String |
CLIENT_METRICS_PATH_DEFAULT |
"/v1/metrics" |
public static final String |
CLIENT_METRICS_PATH_DOC |
"The URL path to post metrics to for metrics (i.e. /v1/metrics_override)" |
public static final String |
CLIENT_REQUEST_TIMEOUT_MS |
"client.request.timeout.ms" |
public static final String |
CLIENT_REQUEST_TIMEOUT_MS_DOCS |
"The request timeout in milliseconds" |
public static final String |
CLIENT_RETRY_DELAY_SEC |
"client.retry.delay.seconds" |
public static final String |
CLIENT_RETRY_DELAY_SEC_DOC |
"The delay, in seconds, between retry attempts" |
public static final String |
PREFIX_BUFFER |
"buffer." |
public static final String |
PREFIX_CLIENT |
"client." |
public static final String |
PREFIX_PROXY |
"proxy." |
public static final String |
PROXY_PASSWORD |
"proxy.password" |
public static final String |
PROXY_PASSWORD_DOC |
"The password credential for the forward HTTP proxy" |
public static final String |
PROXY_URL |
"proxy.url" |
public static final String |
PROXY_URL_DOC |
"The URL for an explicit (i.e. not transparent) forward HTTP proxy" |
public static final String |
PROXY_USERNAME |
"proxy.username" |
public static final String |
PROXY_USERNAME_DOC |
"The username credential for the forward HTTP proxy" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
VERSION_HEADER_KEY |
"v" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BOOTSTRAP_SERVERS_CONFIG |
"producer.bootstrap.servers" |
public static final String |
BOOTSTRAP_SERVERS_DOC |
"Bootstrap servers for the Kafka cluster telemetry will be published to. The target cluster may be different from the cluster(s) whose telemetry is being collected. Several production Kafka clusters can publish to a single target Kafka cluster, for example." |
public static final boolean |
DEFAULT_SUBSET_PARTITIONER_ENABLED |
false |
public static final boolean |
DEFAULT_TOPIC_CREATE |
true |
public static final int |
DEFAULT_TOPIC_MAX_MESSAGE_BYTES |
10485760 |
public static final String |
DEFAULT_TOPIC_NAME |
"_confluent-telemetry-metrics" |
public static final int |
DEFAULT_TOPIC_PARTITIONS |
12 |
public static final int |
DEFAULT_TOPIC_REPLICAS |
3 |
public static final long |
DEFAULT_TOPIC_RETENTION_BYTES |
-1L |
public static final String |
PREFIX_PRODUCER |
"producer." |
public static final String |
PREFIX_TOPIC |
"topic." |
public static final String |
SUBSET_PARTITIONER_ENABLED |
"subset.partitioner.enabled" |
public static final String |
SUBSET_PARTITIONER_ENABLED_DOC |
"Boolean value. True if the Kafka exporter\'s producer should use RandomBrokerPartitionSubsetPartitionerby default" |
public static final String |
TOPIC_CREATE_CONFIG |
"topic.create" |
public static final String |
TOPIC_CREATE_DOC |
"Create the metrics topic if it does not exist." |
public static final String |
TOPIC_MAX_MESSAGE_BYTES_CONFIG |
"topic.max.message.bytes" |
public static final String |
TOPIC_MAX_MESSAGE_BYTES_DOC |
"Maximum message size for the metrics topic." |
public static final String |
TOPIC_NAME_CONFIG |
"topic.name" |
public static final String |
TOPIC_NAME_DOC |
"Topic to which metrics data will be written." |
public static final String |
TOPIC_PARTITIONS_CONFIG |
"topic.partitions" |
public static final String |
TOPIC_PARTITIONS_DOC |
"Number of partitions in the metrics topic." |
public static final String |
TOPIC_REPLICAS_CONFIG |
"topic.replicas" |
public static final String |
TOPIC_REPLICAS_DOC |
"Number of replicas in the metric topic. It must not be higher than the number of brokers in the destination Kafka cluster." |
public static final String |
TOPIC_RETENTION_BYTES_CONFIG |
"topic.retention.bytes" |
public static final String |
TOPIC_RETENTION_BYTES_DOC |
"Retention bytes for the metrics topic." |
public static final String |
TOPIC_RETENTION_MS_CONFIG |
"topic.retention.ms" |
public static final String |
TOPIC_RETENTION_MS_DOC |
"Retention time for the metrics topic." |
public static final String |
TOPIC_ROLL_MS_CONFIG |
"topic.roll.ms" |
public static final String |
TOPIC_ROLL_MS_DOC |
"Log rolling time for the metrics topic." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOMAIN |
"io.confluent.controlcenter" |
public static final String |
NAMESPACE |
"confluent.controlcenter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ADMIN_NAMESPACE |
"kafka.admin.client" |
public static final String |
CONSUMER_NAMESPACE |
"kafka.consumer" |
public static final String |
DOMAIN |
"io.confluent.kafka.client" |
public static final String |
LABEL_CLIENT_ID |
"client.id" |
public static final String |
PRODUCER_NAMESPACE |
"kafka.producer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOMAIN |
"io.confluent.kafka.connect" |
public static final String |
NAMESPACE |
"kafka.connect" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOMAIN |
"io.confluent.kafka.rest" |
public static final String |
NAMESPACE |
"kafka.rest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_BROKER_METRICS_INCLUDE_REGEX |
"io.confluent.kafka.server/.*(acl_authorizer/zookeeper_disconnects/total/delta|acl_authorizer/zookeeper_expires/total/delta|broker_failure/zookeeper_disconnects/total/delta|broker_failure/zookeeper_expires/total/delta|broker_topic/bytes_in/total/delta|broker_topic/bytes_out/total/delta|broker_topic/failed_produce_requests/total/delta|broker_topic/failed_fetch_requests/total/delta|broker_topic/produce_message_conversions/total/delta|broker_topic/fetch_message_conversions/total/delta|cluster_link/active_link_count|cluster_link/consumer_offset_committed_rate|cluster_link/consumer_offset_committed_total|cluster_link/fetch_throttle_time_avg|cluster_link/fetch_throttle_time_max|cluster_link/link_count|cluster_link/linked_leader_epoch_change_rate|cluster_link/linked_leader_epoch_change_total|cluster_link/linked_topic_partition_addition_rate|cluster_link/linked_topic_partition_addition_total|cluster_link/mirror_partition_count|cluster_link/mirror_topic_byte_total|cluster_link/mirror_topic_count|cluster_link/mirror_topic_lag|cluster_link/topic_config_update_rate|cluster_link/topic_config_update_total|cluster_link_fetcher/connection_count|cluster_link_fetcher/failed_reauthentication_rate|cluster_link_fetcher/failed_reauthentication_total|cluster_link_fetcher/incoming_byte_rate|cluster_link_fetcher/incoming_byte_total|cluster_link_fetcher/outgoing_byte_rate|cluster_link_fetcher/outgoing_byte_total|cluster_link_fetcher/reauthentication_latency_avg|cluster_link_fetcher_manager/max_lag|controller/active_controller_count|controller/leader_election_rate_and_time_ms|controller/offline_partitions_count|controller/partition_availability|controller/preferred_replica_imbalance_count|controller/tenant_partition_availability|controller/global_under_min_isr_partition_count|controller/unclean_leader_elections/total|controller_channel/connection_close_rate|controller_channel/connection_close_total|controller_channel/connection_count|controller_channel/connection_creation_rate|controller_channel/connection_creation_total|controller_channel/request_size_avg|controller_channel/request_size_max|controller_channel_manager/queue_size|controller_channel_manager/total_queue_size|controller_event_manager/event_queue_size|delayed_operation_purgatory/purgatory_size|executor/zookeeper_disconnects/total/delta|executor/zookeeper_expires/total/delta|fetch/queue_size|fetcher/bytes_per_sec|fetcher_lag/consumer_lag|group_coordinator/partition_load_time_max|log_cleaner_manager/achieved_cleaning_ratio/time/delta|log_cleaner_manager/achieved_cleaning_ratio/total/delta|log_cleaner_manager/compacted_partition_bytes|log_cleaner_manager/max_dirty_percent|log_cleaner_manager/time_since_last_run_ms|log_cleaner_manager/uncleanable_bytes|log_cleaner_manager/uncleanable_partitions_count|replica_alter_log_dirs_manager/max_lag|replica_fetcher/request_size_avg|replica_fetcher/request_size_max|replica_fetcher_manager/max_lag|replica_manager/blocked_on_mirror_source_partition_count|replica_manager/isr_shrinks|replica_manager/leader_count|replica_manager/partition_count|replica_manager/under_min_isr_mirror_partition_count|replica_manager/under_min_isr_partition_count|replica_manager/under_replicated_mirror_partitions|replica_manager/under_replicated_partitions|request/errors/total/delta|request/local_time_ms/time/delta|request/local_time_ms/total/delta|request/queue_size|request/remote_time_ms/time/delta|request/remote_time_ms/total/delta|request/request_queue_time_ms/time/delta|request/request_queue_time_ms/total/delta|request/requests|request/response_queue_time_ms/time/delta|request/response_queue_time_ms/total/delta|request/response_send_time_ms/time/delta|request/response_send_time_ms/total/delta|request/total_time_ms/time/delta|request/total_time_ms/total/delta|request_channel/request_queue_size|request_channel/response_queue_size|request_handler_pool/request_handler_avg_idle_percent|session_expire_listener/zookeeper_disconnects/total/delta|session_expire_listener/zookeeper_expires/total/delta|socket_server/connections|socket_server/successful_authentication_total/delta|socket_server/failed_authentication_total/delta|socket_server/network_processor_avg_idle_percent|socket_server/request_size_avg|socket_server/request_size_max|tenant/consumer_lag_offsets)" |
public static final String |
DEFAULT_SECURITY_METRICS_INCLUDE_REGEX |
"io.confluent.kafka.server/.*(confluent_audit/audit_log_fallback_rate_per_minute|confluent_audit/audit_log_rate_per_minute|confluent_authorizer/authorization_request_rate_per_minute|confluent_authorizer/authorization_allowed_rate_per_minute|confluent_authorizer/authorization_denied_rate_per_minute|confluent_auth_store/rbac_role_bindings_count|confluent_auth_store/rbac_access_rules_count|confluent_auth_store/acl_access_rules_count)" |
public static final String |
LABEL_BROKER_ID |
"broker.id" |
public static final String |
LABEL_BROKER_RACK |
"broker.rack" |
public static final String |
LABEL_CELL_ID |
"cell.id" |
public static final String |
LABEL_CLUSTER_ID |
"cluster.id" |
public static final String |
LABEL_PROCESS_BROKER |
"process.roles.broker" |
public static final String |
LABEL_PROCESS_CONTROLLER |
"process.roles.controller" |
public static final String |
LABEL_PROCESS_ROLES |
"process.roles" |
public static final String |
NAMESPACE |
"kafka.server" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOMAIN |
"io.confluent.kafka.streams" |
public static final String |
NAMESPACE |
"kafka.streams" |
public static final String |
STREAMS_APPLICATION_ID |
"application.id" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOMAIN |
"io.confluent.ksql" |
public static final String |
KSQL_SERVICE_ID |
"ksql.service.id" |
public static final String |
NAMESPACE |
"io.confluent.ksql.metrics" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOMAIN |
"io.confluent.schema.registry" |
public static final String |
NAMESPACE |
"kafka.schema.registry" |
public static final String |
SCHEMAS_TOPIC_CONFIG |
"kafkastore.topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONNECT_GROUP_ID |
"connect.group.id" |
public static final String |
CONNECT_KAFKA_CLUSTER_ID |
"connect.kafka.cluster.id" |
public static final String |
KAFKA_BROKER_ID |
"kafka.broker.id" |
public static final String |
KAFKA_BROKER_ROLE |
"broker" |
public static final String |
KAFKA_CELL_ID |
"kafka.cell.id" |
public static final String |
KAFKA_CLUSTER_ID |
"kafka.cluster.id" |
public static final String |
KAFKA_CONTROLLER_ROLE |
"controller" |
public static final String |
KAFKA_NODE_ID |
"kafka.node.id" |
public static final String |
KAFKA_PROCESS_ROLES |
"kafka.process.roles" |
public static final String |
LABEL_CLUSTER_ID |
"cluster.id" |
public static final String |
RESOURCE_LABEL_CLUSTER_ID |
"resource.cluster.id" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SELF_METRICS_DOMAIN |
"io.confluent.telemetry" |
public static final String |
SELF_METRICS_NAMESPACE |
"confluent.telemetry" |
public static final String |
TELEMETRY_REPORTER_ID_TAG |
"telemetry-reporter-id" |