Synadia Connect

Elasticsearch

NAMERUNTIMETYPEVERSION
elasticsearchwombatsinklatest

Publishes messages into an Elasticsearch index. If the index does not exist then it is created with a dynamic mapping.

It's possible to enable AWS connectivity with this output using the aws fields. However, you may need to set sniff and healthcheck to false for connections to succeed.


Configuration

NameTypeOptionalSecretDescription
urls[]stringnonoA list of URLs to connect to. If an item of the list contains commas it will be expanded into multiple URLs.
indexstringnonoThe index to place messages.
actionstringyesnoThe action to take on the document. This field must resolve to one of the following action types: create, index, update, upsert or delete. The value defaults to "index".
pipelinestringyesnoAn optional pipeline id to preprocess incoming documents. The value defaults to "".
idstringyesnoThe ID for indexed messages. Interpolation should be used in order to create a unique ID for each message. The value defaults to "${!counter()}-${!timestamp_unix()}".
typestringyesnoThe document mapping type. This field is required for versions of elasticsearch earlier than 6.0.0, but are invalid for versions 7.0.0 or later. The value defaults to "".
routingstringyesnoThe routing key to use for the document. The value defaults to "".
sniffboolyesnoPrompts the connector to sniff for brokers to connect to when establishing a connection. The value defaults to true.
healthcheckboolyesnoWhether to enable healthchecks. The value defaults to true.
timeoutstringyesnoThe maximum time to wait before abandoning a request (and trying again). The value defaults to "5s".
api_keystringnoyesThe key to set in the Authorization header if using API keys for authentication.
tlstlsnonoCustom TLS settings can be used to override system defaults.
max_in_flightintyesnoThe maximum number of messages to have in flight at a given time. Increase this to improve throughput. The value defaults to 64.
max_retriesintyesnoThe maximum number of retries before giving up on the request. If set to zero there is no discrete limit. The value defaults to 0.
backoffbackoffnonoControl time intervals between retry attempts.
basic_authbasic_authnonoAllows you to specify basic authentication.
batchingbatchingnonoAllows you to configure a batching policy.
awsawsnonoEnables and customises connectivity to Amazon Elastic Service.
gzip_compressionboolyesnoEnable gzip compression on the request side. The value defaults to false.

TLS Configuration

NameTypeOptionalSecretDescription
enabledboolyesnoWhether custom TLS settings are enabled. The value defaults to false.
skip_cert_verifyboolyesnoWhether to skip server side certificate verification. The value defaults to false.
enable_renegotiationboolyesnoWhether to allow the remote server to repeatedly request renegotiation.
Enable this option if you're seeing the error message local error: tls: no renegotiation. The value defaults to false.
root_casstringyesyesAn optional root certificate authority to use.
This is a string, representing a certificate chain from the parent trusted root certificate,
to possible intermediate signing certificates, to the host certificate. The value defaults to "".
client_certs[]client_certsyesnoA list of client certificates to use. . The value defaults to [].

Backoff

NameTypeOptionalSecretDescription
initial_intervalstringyesnoThe initial period to wait between retry attempts. The value defaults to "1s".
max_intervalstringyesnoThe maximum period to wait between retry attempts. The value defaults to "5s".
max_elapsed_timestringyesnoThe maximum period to wait before retry attempts are abandoned. If zero then no limit is used. The value defaults to "30s".

Basic Auth

NameTypeOptionalSecretDescription
enabledboolyesnoWhether to use basic authentication in requests. The value defaults to false.
usernamestringyesnoA username to authenticate as. The value defaults to "".
passwordstringyesyesA password to authenticate with. The value defaults to "".

Batching

NameTypeOptionalSecretDescription
countintyesnoA number of messages at which the batch should be flushed. If 0 disables count based batching. The value defaults to 0.
byte_sizeintyesnoAn amount of bytes at which the batch should be flushed. If 0 disables size based batching. The value defaults to 0.
periodstringyesnoA period in which an incomplete batch should be flushed regardless of its size. The value defaults to "".
checkstringyesnoA Bloblang query that should return a boolean value indicating whether a message should end a batch. The value defaults to "".

AWS

NameTypeOptionalSecretDescription
enabledboolyesnoWhether to connect to Amazon Elastic Service. The value defaults to false.
regionstringyesnoThe AWS region to target. The value defaults to "".
endpointstringyesnoAllows you to specify a custom endpoint for the AWS API. The value defaults to "".
credentialscredentialsnonoOptional manual configuration of AWS credentials to use. More information can be found in the AWS Guide.
Previous
Discord