跳到主要内容
版本:2.3.0-beta

Elasticsearch

Description

Output data to Elasticsearch.

Key features

提示

Engine Supported

  • supported ElasticSearch version is >= 2.x and < 8.x

Options

nametyperequireddefault value
hostsarrayyes-
indexstringyes-
index_typestringno
usernamestringno
passwordstringno
max_retry_sizeintno3
max_batch_sizeintno10
common-optionsno-

hosts [array]

Elasticsearch cluster http address, the format is host:port , allowing multiple hosts to be specified. Such as ["host1:9200", "host2:9200"].

index [string]

Elasticsearch index name.Index support contains variables of field name,such as seatunnel_${age},and the field must appear at seatunnel row. If not, we will treat it as a normal index.

index_type [string]

Elasticsearch index type, it is recommended not to specify in elasticsearch 6 and above

username [string]

x-pack username

password [string]

x-pack password

max_retry_size [int]

one bulk request max try size

max_batch_size [int]

batch bulk doc max size

common options

Sink plugin common parameters, please refer to Sink Common Options for details

Examples

Elasticsearch {
hosts = ["localhost:9200"]
index = "seatunnel-${age}"
}

Changelog

2.2.0-beta 2022-09-26

  • Add Elasticsearch Sink Connector