Azure Event Hubs destination plugin

The Azure Event Hubs destination plugin lets you configure Chronosphere Telemetry Pipeline to stream your logs and metrics data directly to Azure Event Hubs.

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
Event Hub NamespacebrokersRequired. The Event Hubs namespace that can be found within the configuration settings.none
Event Hub TopictopicsRequired. The Event Hubs topic to write information to.none
Connection String Keyrdkafka.sasl.passwordRequired. The Event Hubs connection string from within the Connection Access Policy set for the source.none

Advanced

NameKeyDescriptionDefault
Message Keymessage_keyOptional Key to store the message.none
Message Key Fieldmessage_key_fieldIf set, this value indicates the message key. If not set or found in the record, message_key will be used (if set).none
Timestamp Keytimestamp_keySet the key to store the record timestamp.none
Timestamp Formattimestamp_formatSet the timestamp format. Accepted values: double, iso8601.double
Body Keybody_keySpecify the key which contains the body.none
Queue Full Retriesqueue_full_retriesFluent Bit queues data into rdkafka library, if for some reason the underlying library can't flush the records the queue might fills up blocking new addition of records. The queue_full_retries option set the number of local retries to enqueue the data. The default value is 10 times, the interval between each retry is 1 second. Setting the queue_full_retries value to 0 sets an unlimited number of retries.10
SASL Usernamerdkafka.sasl.usernameSASL username.$ConnectionString
Security Protocolrdkafka.security.protocolThis is the security protocol for Azure Event Hub. If you require OAuth or OpenID, open a support ticket prior to changing this setting.SASL_SSL
SASL Mechanismrdkafka.sasl.mechanismThis is the transport mechanism for the SASL connection.PLAIN