Skip to main content

ElasticSearch Connector

Sink

The ElasticSearch Sink Connector is used to pull messages from Pulsar topics and persist the messages to a index.

Sink Configuration Options

NameDefaultRequiredDescription
elasticSearchUrlnulltrueThe url of elastic search cluster that the connector connects to.
indexNamenulltrueThe index name that the connector writes messages to.
indexNumberOfShards1falseThe number of shards of the index.
indexNumberOfReplicas1falseThe number of replicas of the index.
usernamenullfalseThe username used by the connector to connect to the elastic search cluster. If username is set, a password should also be provided.
passwordnullfalseThe password used by the connector to connect to the elastic search cluster. If password is set, a username should also be provided.