Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLOUD_EVENT_BINARY_ENCODING |
"binary" |
public static final String |
CLOUD_EVENT_ENCODING_CONFIG |
"event.logger.cloudevent.codec" |
public static final String |
CLOUD_EVENT_ENCODING_DOC |
"Which cloudevent encoding to use. Use structured encoding by default" |
public static final String |
CLOUD_EVENT_STRUCTURED_ENCODING |
"structured" |
public static final String |
DEFAULT_CLOUD_EVENT_ENCODING_CONFIG |
"structured" |
public static final String |
EVENT_EXPORTER_CLASS_CONFIG |
"event.logger.exporter.class" |
public static final String |
EVENT_EXPORTER_CLASS_DOC |
"Class to use for delivering event logs." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARTITION_KEY |
"partitionkey" |
public static final String |
ROUTE |
"route" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENABLED_CONFIG |
"enabled" |
public static final boolean |
ENABLED_CONFIG_DEFAULT |
true |
public static final String |
ENABLED_CONFIG_DOC |
"Boolean value. True exporter should be enabled, false otherwise." |
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 |
PREFIX_EVENTS |
"events." |
public static final String |
PREFIX_EXPORTER |
"confluent.telemetry.exporter." |
public static final String |
TYPE_CONFIG |
"type" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
V1_EVENTS_ENDPOINT |
"/v1/events" |
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_MAX_ATTEMPTS |
"client.attempts.max" |
public static final String |
CLIENT_MAX_ATTEMPTS_DOC |
"The maximum number of delivery attempts" |
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 |
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 String |
CLOUD_EVENT_BINARY_ENCODING |
"binary" |
public static final String |
CLOUD_EVENT_ENCODING_CONFIG |
"cloudevent.codec" |
public static final String |
CLOUD_EVENT_ENCODING_DOC |
"Which cloudevent encoding to use. Use structured encoding by default" |
public static final String |
CLOUD_EVENT_STRUCTURED_ENCODING |
"structured" |
public static final String |
DEFAULT_CLOUD_EVENT_ENCODING_CONFIG |
"binary" |
public static final int |
DEFAULT_EVENT_QUEUE_SIZE |
500 |
public static final int |
DEFAULT_MIN_ISR |
1 |
public static final int |
DEFAULT_PRODUCER_CLOSE_TIMEOUT |
15 |
public static final boolean |
DEFAULT_TOPIC_CREATE |
true |
public static final int |
DEFAULT_TOPIC_MAX_MESSAGE_BYTES |
8388608 |
public static final String |
DEFAULT_TOPIC_NAME |
"_confluent-telemetry-events" |
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 |
EVENT_QUEUE_SIZE |
"event.queue.size" |
public static final String |
EVENT_QUEUE_SIZE_DOC |
"Size of event queue" |
public static final int |
MAX_REQUEST_SIZE |
8388608 |
public static final String |
PREFIX_PRODUCER |
"producer." |
public static final String |
PREFIX_TOPIC |
"topic." |
public static final String |
TOPIC_CREATE_CONFIG |
"topic.create" |
public static final String |
TOPIC_CREATE_DOC |
"Create the 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 topic." |
public static final String |
TOPIC_NAME_CONFIG |
"topic.name" |
public static final String |
TOPIC_NAME_DOC |
"Topic to which telemetry 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 events topic." |
public static final String |
TOPIC_REPLICAS_CONFIG |
"topic.replicas" |
public static final String |
TOPIC_REPLICAS_DOC |
"Number of replicas in the telemetry 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 topic." |
public static final String |
TOPIC_RETENTION_MS_CONFIG |
"topic.retention.ms" |
public static final String |
TOPIC_RETENTION_MS_DOC |
"Retention time for the 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 topic." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_LOG_EVENT_EXPORTER_NAME_CONFIG |
"event" |
public static final String |
LOG_EVENT_EXPORTER_NAME_CONFIG |
"event.logger.exporter.log.name" |
public static final String |
LOG_EVENT_EXPORTER_NAME_DOC |
"Name for the logger, used in getLogger()" |