Skip navigation links
A B C D E F G H I K L M N O P R S T U V W 

A

API_KEY - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
API_KEY_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
API_SECRET - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
API_SECRET_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
AsyncKafkaExporter<T> - Class in io.confluent.telemetry.events.exporter.kafka.async
This KafkaExporter does not block the calling thread.
AsyncKafkaExporter(int, TopicSupplier<T>, Producer<String, byte[]>, Function<T, ProducerRecord<String, byte[]>>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
AsyncKafkaExporter(Properties, int, TopicSupplier<T>, Function<T, ProducerRecord<String, byte[]>>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
AsyncKafkaExporter.Builder<T> - Class in io.confluent.telemetry.events.exporter.kafka.async
 

B

BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
buffer() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
BUFFER_MAX_BATCH_DURATION_MS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_BATCH_DURATION_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_BATCH_SIZE - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_BATCH_SIZE_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_INFLIGHT_SUBMISSIONS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_PENDING_BATCHES - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
BUFFER_MAX_PENDING_BATCHES_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
bufferingClient - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
bufferSize - Variable in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
build() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
build() - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder
 
Builder() - Constructor for class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
Builder() - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder
 

C

canEmitTelemetry() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_BASE_URL - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_BASE_URL_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_COMPRESSION - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_COMPRESSION_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_MAX_ATTEMPTS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_MAX_ATTEMPTS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_REQUEST_TIMEOUT_MS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_REQUEST_TIMEOUT_MS_DOCS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_RETRY_DELAY_SEC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
CLIENT_RETRY_DELAY_SEC_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
close() - Method in class io.confluent.telemetry.events.EventEmitterImpl
 
close() - Method in class io.confluent.telemetry.events.EventLogger
 
close() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
close() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
close() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
close() - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
 
close() - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
CLOUD_EVENT_BINARY_ENCODING - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
CLOUD_EVENT_BINARY_ENCODING - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
CLOUD_EVENT_ENCODING_DOC - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
CLOUD_EVENT_ENCODING_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
CLOUD_EVENT_STRUCTURED_ENCODING - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
CLOUD_EVENT_STRUCTURED_ENCODING - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
config - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventEmitterImpl
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventKafkaExporter
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
create(Map<String, ?>) - Method in interface io.confluent.telemetry.events.EventLoggerFactory
 

D

dataSerializer - Variable in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
DEFAULT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
DEFAULT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_EVENT_QUEUE_SIZE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_LOG_EVENT_EXPORTER_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig
 
DEFAULT_MIN_ISR - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_PRODUCER_CLOSE_TIMEOUT - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_SUBSET_PARTITIONER_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_SUBSET_PARTITIONER_PARTITION_PERCENTAGE - Static variable in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
 
DEFAULT_TOPIC_CREATE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_MAX_MESSAGE_BYTES - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_NAME - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_PARTITIONS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_REPLICAS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_RETENTION_BYTES - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_RETENTION_MS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
DEFAULT_TOPIC_ROLL_MS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
droppedEventCount - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
droppedEventException - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 

E

emit(Event) - Method in class io.confluent.telemetry.events.EventEmitterImpl
 
emit(T) - Method in interface io.confluent.telemetry.events.exporter.Exporter
Filter and transform the events as appropriate and send to the specified destination.
emit(Data) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
emit(T) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
emit(T) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
emit(Event) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
ENABLED_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
endpoint - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
ensureValid(String, Object) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig.URIValidator
 
EVENT_EXPORTER_CLASS_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
EVENT_EXPORTER_CLASS_DOC - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
EVENT_QUEUE_SIZE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
EVENT_QUEUE_SIZE_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
EventAsyncKafkaExporter - Class in io.confluent.telemetry.events.exporter.kafka
 
EventAsyncKafkaExporter(EventAsyncKafkaExporter.Builder) - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter
 
EventAsyncKafkaExporter.Builder - Class in io.confluent.telemetry.events.exporter.kafka
 
EventEmitterConfig - Class in io.confluent.telemetry.events
EventEmitterConfig uses a hash map to save exporter configs, key is event type: events/metrics, value is a hash map, key is exporter name, value is a map of exporter configs.
EventEmitterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventEmitterConfig
 
EventEmitterConfig.EventType - Enum in io.confluent.telemetry.events
 
EventEmitterImpl - Class in io.confluent.telemetry.events
 
EventEmitterImpl(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventEmitterImpl
 
eventExporter() - Method in class io.confluent.telemetry.events.EventLogger
 
EventHttpExporter - Class in io.confluent.telemetry.events.exporter.http
 
EventHttpExporter() - Constructor for class io.confluent.telemetry.events.exporter.http.EventHttpExporter
 
EventKafkaExporter - Class in io.confluent.telemetry.events.exporter.kafka
 
EventKafkaExporter() - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventKafkaExporter
 
EventLogger - Class in io.confluent.telemetry.events
This creates a logger that writes events to the configured exporter.
EventLogger() - Constructor for class io.confluent.telemetry.events.EventLogger
 
EventLogger(Function<EventLoggerConfig, Exporter<Event>>) - Constructor for class io.confluent.telemetry.events.EventLogger
 
EventLoggerConfig - Class in io.confluent.telemetry.events
 
EventLoggerConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventLoggerConfig
 
EventLoggerFactory - Interface in io.confluent.telemetry.events
 
EVENTS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
EVENTS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
EVENTS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
EventUtils - Class in io.confluent.telemetry.events
 
EventUtils() - Constructor for class io.confluent.telemetry.events.EventUtils
 
Exporter<T> - Interface in io.confluent.telemetry.events.exporter
Exporters are responsible for delivering events to their destinations
EXPORTER_COMMON_CONFIG_PREFIXES - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
EXPORTER_COMMON_CONFIGS - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
ExporterConfig - Class in io.confluent.telemetry.events.exporter
 
ExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.ExporterConfig
 
ExporterConfig(ConfigDef, Map<?, ?>) - Constructor for class io.confluent.telemetry.events.exporter.ExporterConfig
 
ExporterConfig(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.events.exporter.ExporterConfig
 
ExporterConfig.ExporterType - Enum in io.confluent.telemetry.events.exporter
 
ExporterUtils - Class in io.confluent.telemetry
 
ExporterUtils() - Constructor for class io.confluent.telemetry.ExporterUtils
 
Extensions - Interface in io.confluent.telemetry.events
 

F

filter - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
format - Static variable in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter
 

G

getBufferingAsyncClientBuilder() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
getClientBuilder() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
getCompressionAlgorithm(String) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
Get the compression algorithm.
getCredentials() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
getEnabledExporterConfigs(EventEmitterConfig.EventType) - Method in class io.confluent.telemetry.events.EventEmitterConfig
Get exporter configs of a certain event type, only enabled exporters are returned
getEncoding() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
getNonInternalExporterConfigs(EventEmitterConfig.EventType) - Method in class io.confluent.telemetry.events.EventEmitterConfig
 
getProxyConfig() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 

H

HttpExporter<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite> - Class in io.confluent.telemetry.events.exporter.http
 
HttpExporter() - Constructor for class io.confluent.telemetry.events.exporter.http.HttpExporter
 
HttpExporterConfig - Class in io.confluent.telemetry.events.exporter.http
Configuration for the HttpExporter.
HttpExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
HttpExporterConfig.URIValidator - Class in io.confluent.telemetry.events.exporter.http
 

I

io.confluent.telemetry - package io.confluent.telemetry
 
io.confluent.telemetry.events - package io.confluent.telemetry.events
 
io.confluent.telemetry.events.exporter - package io.confluent.telemetry.events.exporter
 
io.confluent.telemetry.events.exporter.http - package io.confluent.telemetry.events.exporter.http
 
io.confluent.telemetry.events.exporter.kafka - package io.confluent.telemetry.events.exporter.kafka
 
io.confluent.telemetry.events.exporter.kafka.async - package io.confluent.telemetry.events.exporter.kafka.async
 
io.confluent.telemetry.events.exporter.log - package io.confluent.telemetry.events.exporter.log
 
isEventExporter(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig
 
isEventsExporterEnabled(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig
 
isInternalExporter(String) - Method in class io.confluent.telemetry.events.EventEmitterConfig
 
isKafkaExporter(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig
 

K

KafkaExporter<T> - Class in io.confluent.telemetry.events.exporter.kafka
 
KafkaExporter() - Constructor for class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
KafkaExporter(Function<Properties, Producer<String, byte[]>>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
KafkaExporterConfig - Class in io.confluent.telemetry.events.exporter.kafka
 
KafkaExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
kafkaProducer - Variable in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 

L

lastLoggedCount - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
lastLoggedTimestamp - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
log(Event) - Method in class io.confluent.telemetry.events.EventLogger
Log an event.
LOG_EVENT_EXPORTER_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig
 
LOG_EVENT_EXPORTER_NAME_DOC - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig
 
LogExporter - Class in io.confluent.telemetry.events.exporter.log
The LogExporter sends events to the SLF4J-configured log file
LogExporter() - Constructor for class io.confluent.telemetry.events.exporter.log.LogExporter
 
LogExporterConfig - Class in io.confluent.telemetry.events.exporter.log
 
LogExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.log.LogExporterConfig
 

M

main(String[]) - Static method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
main(String[]) - Static method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
MAX_REQUEST_SIZE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
METRICS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
METRICS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
METRICS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 

N

newBuilder() - Static method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
newBuilder(Map<String, Object>) - Static method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter
 

O

onNewBatch(String, Cluster, int) - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
We need to deal with topology changes and redefine which partitions to write to.

P

parseExporterConfigsByName(Map<String, Map<String, Object>>, Map<String, Object>) - Static method in class io.confluent.telemetry.ExporterUtils
 
parseType(Object) - Static method in class io.confluent.telemetry.events.exporter.ExporterConfig
 
partition(String, Object, byte[], Object, byte[], Cluster) - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
Choose the partition for a record from partitions found on a limited number of brokers according to `subset.partitioner.partition.percentage`.
PARTITION_KEY - Static variable in interface io.confluent.telemetry.events.Extensions
 
PREFIX_BUFFER - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PREFIX_CLIENT - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PREFIX_EVENTS - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
PREFIX_EXPORTER - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
PREFIX_PRODUCER - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
PREFIX_PROXY - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PREFIX_TOPIC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
producer() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
producer() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
PRODUCER_CONFIG_DEFAULTS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
producerProperties - Variable in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
protoToBytes(Message, String) - Static method in class io.confluent.telemetry.events.EventUtils
 
PROXY_PASSWORD - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PROXY_PASSWORD_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PROXY_URL - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PROXY_URL_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PROXY_USERNAME - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
PROXY_USERNAME_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 

R

RandomBrokerPartitionSubsetPartitioner - Class in io.confluent.telemetry.events.exporter.kafka
A partitioner that reduces the number of connections a producer needs to make by Specifying a subset percentage of total partitions to produce to Randomly connecting to brokers and taking all partitions on that broker until it has connected to the subset of partitions Randomly produce to the recorded partitions NOTE: This partitioner will not respect keys when determining the partition to be used. This is done so that keyed messages do not result in connections to every broker.
RandomBrokerPartitionSubsetPartitioner() - Constructor for class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
 
ready(Event) - Method in class io.confluent.telemetry.events.EventLogger
Check if the event exporter ready for sending events.
RECONFIGURABLE_CONFIGS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
RECONFIGURABLE_CONFIGS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
reconfigurableConfigs() - Method in class io.confluent.telemetry.events.EventLogger
 
reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
RECONFIGURABLES - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger
 
reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
requestConverter - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
requestSerializer - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
responseDeserializer - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
responseDeserializer - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
ROUTE - Static variable in interface io.confluent.telemetry.events.Extensions
 
routeReady(T) - Method in interface io.confluent.telemetry.events.exporter.Exporter
Checks if a topic is ready.
routeReady(Event) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 

S

setEventLabels(Map<String, String>) - Method in class io.confluent.telemetry.events.EventEmitterImpl
 
SingleTopicSupplier<T> - Class in io.confluent.telemetry.events.exporter.kafka.async
 
SingleTopicSupplier(NewTopic, Properties) - Constructor for class io.confluent.telemetry.events.exporter.kafka.async.SingleTopicSupplier
 
SUBSET_PARTITIONER_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
SUBSET_PARTITIONER_ENABLED_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
SUBSET_PARTITIONER_PARTITION_PERCENTAGE_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner
 

T

toCloudEvent(Event) - Static method in class io.confluent.telemetry.events.EventUtils
 
toJson(Event) - Static method in class io.confluent.telemetry.events.EventUtils
 
toJson(CloudEvent) - Static method in class io.confluent.telemetry.events.EventUtils
 
topic(T) - Method in class io.confluent.telemetry.events.exporter.kafka.async.SingleTopicSupplier
 
topic(T) - Method in interface io.confluent.telemetry.events.exporter.kafka.async.TopicSupplier
Get a topic for the record.
TOPIC_CREATE_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_CREATE_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_MAX_MESSAGE_BYTES_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_MAX_MESSAGE_BYTES_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_NAME_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_PARTITIONS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_REPLICAS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_RETENTION_BYTES_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_RETENTION_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
TOPIC_ROLL_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig
 
topicName - Variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
topicSupplier - Variable in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
TopicSupplier<T> - Interface in io.confluent.telemetry.events.exporter.kafka.async
 
TYPE_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 
TYPE_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig
 

U

URIValidator() - Constructor for class io.confluent.telemetry.events.exporter.http.HttpExporterConfig.URIValidator
 

V

V1_EVENTS_ENDPOINT - Static variable in class io.confluent.telemetry.events.exporter.http.EventHttpExporter
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
valueOf(String) - Static method in enum io.confluent.telemetry.events.EventEmitterConfig.EventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.telemetry.events.EventEmitterConfig.EventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType
Returns an array containing the constants of this enum type, in the order they are declared.

W

withBufferSize(int) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
withBufferSize(int) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder
 
withDataSerializer(Function<T, ProducerRecord<String, byte[]>>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
withDataSerializer(Function<Event, ProducerRecord<String, byte[]>>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder
 
withProducerProperties(Properties) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
withProducerProperties(Properties) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder
 
withTopicSupplier(TopicSupplier<T>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder
 
withTopicSupplier(TopicSupplier<Event>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder
 
A B C D E F G H I K L M N O P R S T U V W 
Skip navigation links