Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"confluent.metrics.reporter.bootstrap.servers" |
public static final java.lang.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 java.lang.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 java.lang.String |
METRICS_REPORTER_PREFIX |
"confluent.metrics.reporter." |
public static final java.lang.String |
PUBLISH_PERIOD_CONFIG |
"confluent.metrics.reporter.publish.ms" |
public static final java.lang.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 java.lang.String |
TOPIC_CONFIG |
"confluent.metrics.reporter.topic" |
public static final java.lang.String |
TOPIC_CREATE_CONFIG |
"confluent.metrics.reporter.topic.create" |
public static final java.lang.String |
TOPIC_CREATE_DOC |
"Create the metrics topic if it does not exist." |
public static final java.lang.String |
TOPIC_DOC |
"Topic on which metrics data will be written." |
public static final java.lang.String |
TOPIC_MAX_MESSAGE_BYTES_CONFIG |
"confluent.metrics.reporter.topic.max.message.bytes" |
public static final java.lang.String |
TOPIC_MAX_MESSAGE_BYTES_DOC |
"Maximum message size for the metrics topic." |
public static final java.lang.String |
TOPIC_PARTITIONS_CONFIG |
"confluent.metrics.reporter.topic.partitions" |
public static final java.lang.String |
TOPIC_PARTITIONS_DOC |
"Number of partitions in the metrics topic." |
public static final java.lang.String |
TOPIC_REPLICAS_CONFIG |
"confluent.metrics.reporter.topic.replicas" |
public static final java.lang.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 java.lang.String |
TOPIC_RETENTION_BYTES_CONFIG |
"confluent.metrics.reporter.topic.retention.bytes" |
public static final java.lang.String |
TOPIC_RETENTION_BYTES_DOC |
"Retention bytes for the metrics topic." |
public static final java.lang.String |
TOPIC_RETENTION_MS_CONFIG |
"confluent.metrics.reporter.topic.retention.ms" |
public static final java.lang.String |
TOPIC_RETENTION_MS_DOC |
"Retention time for the metrics topic." |
public static final java.lang.String |
TOPIC_ROLL_MS_CONFIG |
"confluent.metrics.reporter.topic.roll.ms" |
public static final java.lang.String |
TOPIC_ROLL_MS_DOC |
"Log rolling time for the metrics topic." |
public static final java.lang.String |
VOLUME_METRICS_REFRESH_PERIOD_DOC |
"The minimum interval at which to fetch new volume metrics." |
public static final java.lang.String |
VOLUME_METRICS_REFRESH_PERIOD_MS |
"confluent.metrics.reporter.volume.metrics.refresh.ms" |
public static final java.lang.String |
WHITELIST_CONFIG |
"confluent.metrics.reporter.whitelist" |
public static final java.lang.String |
WHITELIST_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." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
EMPTY_STRING |
"" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COLLECT_INTERVAL_CONFIG |
"confluent.telemetry.metrics.collector.interval.ms" |
public static final java.lang.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 java.lang.String |
DEBUG_ENABLED |
"confluent.telemetry.debug.enabled" |
public static final java.lang.String |
DEBUG_ENABLED_DOC |
"Enable debug metadata for metrics collection" |
public static final boolean |
DEFAULT_DEBUG_ENABLED |
false |
public static final java.lang.String |
EXPORTER_HTTP_ENABLED_CONFIG |
"confluent.telemetry.exporter.http.enabled" |
public static final boolean |
EXPORTER_HTTP_ENABLED_DEFAULT |
false |
public static final java.lang.String |
EXPORTER_HTTP_ENABLED_DOC |
"True if the HttpExporter is enabled." |
public static final java.lang.String |
EXPORTER_KAFKA_ENABLED_CONFIG |
"confluent.telemetry.exporter.kafka.enabled" |
public static final boolean |
EXPORTER_KAFKA_ENABLED_DEFAULT |
true |
public static final java.lang.String |
EXPORTER_KAFKA_ENABLED_DOC |
"True if the KafkaExporter is enabled." |
public static final java.lang.String |
LEGACY_PREFIX |
"confluent.telemetry.metrics.reporter." |
public static final java.lang.String |
PREFIX |
"confluent.telemetry." |
public static final java.lang.String |
PREFIX_EXPORTER |
"confluent.telemetry.exporter." |
public static final java.lang.String |
PREFIX_LABELS |
"confluent.telemetry.labels." |
public static final java.lang.String |
PREFIX_METRICS_COLLECTOR |
"confluent.telemetry.metrics.collector." |
public static final java.lang.String |
WHITELIST_CONFIG |
"confluent.telemetry.metrics.collector.whitelist" |
public static final java.lang.String |
WHITELIST_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 Confluent Control Center and Confluent Auto Data Balancer. This should typically never be modified unless requested by Confluent." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KAFKA_METRICS_LIB |
"kafka" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LABEL_COLLECTOR |
"collector" |
public static final java.lang.String |
LABEL_LIBRARY |
"library" |
public static final java.lang.String |
LABEL_ORIGINAL |
"metric_name_original" |
public static final java.lang.String |
LIBRARY_NONE |
"none" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
VOLUME_LABEL |
"volume" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_VOLUME_METRICS_UPDATE_PERIOD |
15000L |
public static final java.lang.String |
PREFIX |
"confluent.telemetry.metrics.collector.volume." |
public static final java.lang.String |
VOLUME_METRICS_UPDATE_PERIOD_DOC |
"The minimum interval at which to fetch new volume metrics." |
public static final java.lang.String |
VOLUME_METRICS_UPDATE_PERIOD_MS |
"confluent.telemetry.metrics.collector.volume.update.ms" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
YAMMER_METRICS |
"yammer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
GROUP |
"http_exporter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
API_KEY |
"confluent.telemetry.exporter.http.api.key" |
public static final java.lang.String |
API_KEY_DOC |
"The API key used to authenticate with the Confluent telemetry API" |
public static final java.lang.String |
API_SECRET_KEY |
"confluent.telemetry.exporter.http.api.key.secret" |
public static final java.lang.String |
API_SECRET_KEY_DOC |
"The API secret key used to authenticate with the Confluent Telemetry API" |
public static final java.lang.String |
BUFFER_MAX_BATCH_DURATION_MS |
"confluent.telemetry.exporter.http.buffer.batch.duration.max.ms" |
public static final java.lang.String |
BUFFER_MAX_BATCH_DURATION_MS_DOC |
"The maximum duration (in millis) to buffer items before sending them upstream" |
public static final java.lang.String |
BUFFER_MAX_BATCH_SIZE |
"confluent.telemetry.exporter.http.buffer.batch.items.max" |
public static final java.lang.String |
BUFFER_MAX_BATCH_SIZE_DOC |
"The maximum number of items to buffer into a batch before sending them upstream" |
public static final java.lang.String |
BUFFER_MAX_INFLIGHT_SUBMISSIONS |
"confluent.telemetry.exporter.http.buffer.inflight.submissions.max" |
public static final java.lang.String |
BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC |
"The maximum number of in-flight calls to the HTTP service" |
public static final java.lang.String |
BUFFER_MAX_PENDING_BATCHES |
"confluent.telemetry.exporter.http.buffer.pending.batches.max" |
public static final java.lang.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 java.lang.String |
CLIENT_BASE_URL |
"confluent.telemetry.exporter.http.client.base.url" |
public static final java.lang.String |
CLIENT_BASE_URL_DOC |
"The base URL for the telemetry receiver (i.e. https://host:port)" |
public static final java.lang.String |
CLIENT_COMPRESSION |
"confluent.telemetry.exporter.http.client.compression" |
public static final java.lang.String |
CLIENT_COMPRESSION_DOC |
"HTTP Compression algorithm to use. Either gzip, lz4, or zstd." |
public static final java.lang.String |
CLIENT_CONNECT_TIMEOUT_MS |
"confluent.telemetry.exporter.http.client.connect.timeout.ms" |
public static final java.lang.String |
CLIENT_CONNECT_TIMEOUT_MS_DOC |
"The connect timeout in milliseconds" |
public static final java.lang.String |
CLIENT_MAX_ATTEMPTS |
"confluent.telemetry.exporter.http.client.attempts.max" |
public static final java.lang.String |
CLIENT_MAX_ATTEMPTS_DOC |
"The maximum number of delivery attempts" |
public static final java.lang.String |
CLIENT_REQUEST_TIMEOUT_MS |
"confluent.telemetry.exporter.http.client.request.timeout.ms" |
public static final java.lang.String |
CLIENT_REQUEST_TIMEOUT_MS_DOCS |
"The request timeout in milliseconds" |
public static final java.lang.String |
CLIENT_RETRY_DELAY_SEC |
"confluent.telemetry.exporter.http.client.retry.delay.seconds" |
public static final java.lang.String |
CLIENT_RETRY_DELAY_SEC_DOC |
"The delay, in seconds, between retry attempts" |
public static final java.lang.String |
PREFIX |
"confluent.telemetry.exporter.http." |
public static final java.lang.String |
PREFIX_BUFFER |
"confluent.telemetry.exporter.http.buffer." |
public static final java.lang.String |
PREFIX_CLIENT |
"confluent.telemetry.exporter.http.client." |
public static final java.lang.String |
PREFIX_PROXY |
"confluent.telemetry.exporter.http.proxy." |
public static final java.lang.String |
PROXY_PASSWORD |
"confluent.telemetry.exporter.http.proxy.password" |
public static final java.lang.String |
PROXY_PASSWORD_DOC |
"The password credential for the forward HTTP proxy" |
public static final java.lang.String |
PROXY_URL |
"confluent.telemetry.exporter.http.proxy.url" |
public static final java.lang.String |
PROXY_URL_DOC |
"The URL for an explicit (i.e. not transparent) forward HTTP proxy" |
public static final java.lang.String |
PROXY_USERNAME |
"confluent.telemetry.exporter.http.proxy.username" |
public static final java.lang.String |
PROXY_USERNAME_DOC |
"The username credential for the forward HTTP proxy" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"confluent.telemetry.exporter.kafka.producer.bootstrap.servers" |
public static final java.lang.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_TOPIC_CREATE |
true |
public static final int |
DEFAULT_TOPIC_MAX_MESSAGE_BYTES |
10485760 |
public static final java.lang.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 java.lang.String |
PREFIX |
"confluent.telemetry.exporter.kafka." |
public static final java.lang.String |
PREFIX_PRODUCER |
"confluent.telemetry.exporter.kafka.producer." |
public static final java.lang.String |
PREFIX_TOPIC |
"confluent.telemetry.exporter.kafka.topic." |
public static final java.lang.String |
TOPIC_CREATE_CONFIG |
"confluent.telemetry.exporter.kafka.topic.create" |
public static final java.lang.String |
TOPIC_CREATE_DOC |
"Create the metrics topic if it does not exist." |
public static final java.lang.String |
TOPIC_MAX_MESSAGE_BYTES_CONFIG |
"confluent.telemetry.exporter.kafka.topic.max.message.bytes" |
public static final java.lang.String |
TOPIC_MAX_MESSAGE_BYTES_DOC |
"Maximum message size for the metrics topic." |
public static final java.lang.String |
TOPIC_NAME_CONFIG |
"confluent.telemetry.exporter.kafka.topic.name" |
public static final java.lang.String |
TOPIC_NAME_DOC |
"Topic to which metrics data will be written." |
public static final java.lang.String |
TOPIC_PARTITIONS_CONFIG |
"confluent.telemetry.exporter.kafka.topic.partitions" |
public static final java.lang.String |
TOPIC_PARTITIONS_DOC |
"Number of partitions in the metrics topic." |
public static final java.lang.String |
TOPIC_REPLICAS_CONFIG |
"confluent.telemetry.exporter.kafka.topic.replicas" |
public static final java.lang.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 java.lang.String |
TOPIC_RETENTION_BYTES_CONFIG |
"confluent.telemetry.exporter.kafka.topic.retention.bytes" |
public static final java.lang.String |
TOPIC_RETENTION_BYTES_DOC |
"Retention bytes for the metrics topic." |
public static final java.lang.String |
TOPIC_RETENTION_MS_CONFIG |
"confluent.telemetry.exporter.kafka.topic.retention.ms" |
public static final java.lang.String |
TOPIC_RETENTION_MS_DOC |
"Retention time for the metrics topic." |
public static final java.lang.String |
TOPIC_ROLL_MS_CONFIG |
"confluent.telemetry.exporter.kafka.topic.roll.ms" |
public static final java.lang.String |
TOPIC_ROLL_MS_DOC |
"Log rolling time for the metrics topic." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KAFKA |
"kafka" |
public static final java.lang.String |
LABEL_BROKER_ID |
"broker.id" |
public static final java.lang.String |
LABEL_CLUSTER_ID |
"cluster.id" |