TELEMETRY PIPELINE
Confluent Cloud

Confluent Cloud DataSet destination plugin

The Confluent Cloud destination plugin lets you send Chronosphere Telemetry Pipeline data to Confluent Cloud.

Supported telemetry types

This plugin supports these telemetry types:

LogsMetricsTraces

Configuration parameters

Use the parameters in this section to configure your plugin. The Telemetry Pipeline web interface uses the values in the Name column to describe the parameters. Items in the Key column are the YAML keys to use in pipeline configuration files.

General

NameKeyDescriptionDefault
Confluent Cloud Bootstrap ServersbrokersRequired. The Confluent Cloud bootstrap servers can be found within the cluster configuration settings.SERVERNAME.confluent.cloud:9092
Confluent Cloud TopictopicsRequired. The Confluent Cloud Topic to send information to.none
Confluent Cloud API Keyrdkafka.sasl.usernameRequired. Confluent Cloud API Key.none
Confluent Cloud API Secretrdkafka.sasl.passwordRequired. The Confluent Cloud API Secret.none
FormatformatSpecifies a data format. Accepted values: json, msgpack.json

Advanced

NameKeyDescriptionDefault
Message Keymessage_keyOptional key to store the message.none
Message Key Fieldmessage_key_fieldIf set, the value of Message_Key_Field in the record will indicate the message key. If not set nor found in the record, Message_Key will be used if set.none
Timestamp Keytimestamp_keySets the key to store the record timestamp.none
Timestamp Formattimestamp_formatSets the format. Accepted values: double, iso8601.double
Body Keybody_keySpecifies the key that contains the body.none
Queue Full Retriesqueue_full_retriesTelemetry Pipeline queues data into rdkafka library. If the underlying library can't flush the records the queue might fill and block new addition of records. This option sets the number of local retries to enqueue the data. The interval between each retry is 1 second. Setting queue_full_retries to 0 to set an unlimited number of retries.10
Security Protocolrdkafka.security.protocolThe security protocol used to communicate with Confluent Cloud.SASL_SSL
SASL Mechanismrdkafka.sasl.mechanismsThe SASL authentication mechanism for the API.PLAIN