ElasticSearch sink connector

The ElasticSearch sink connector pulls messages from Pulsar topics and persists the messages to indexes.

Configuration

The configuration of the ElasticSearch sink connector has the following properties.

Name	Type	Required	Default	Description
`elasticSearchUrl`	String	true	" " (empty string)	The URL of elastic search cluster to which the connector connects.
`indexName`	String	true	" " (empty string)	The index name to which the connector writes messages.
`indexNumberOfShards`	int	false	1	The number of shards of the index.
`indexNumberOfReplicas`	int	false	1	The number of replicas of the index.
`username`	String	false	" " (empty string)	The username used by the connector to connect to the elastic search cluster. If `username` is set, then `password` should also be provided.
`password`	String	false	" " (empty string)	The password used by the connector to connect to the elastic search cluster. If `username` is set, then `password` should also be provided.

Before using the ElasticSearch sink connector, you need to create a configuration file through one of the following methods.

JSON

{
    "elasticSearchUrl": "http://localhost:90902",
    "indexName": "myIndex",
    "username": "scooby",
    "password": "doobie"
}

YAML

configs:
    elasticSearchUrl: "http://localhost:90902"
    indexName: "myIndex"
    username: "scooby"
    password: "doobie"