Solr sink connector
You can download all the Pulsar connectors on download page.
The Solr sink connector pulls messages from Pulsar topics and persists the messages to Solr collections.
Configuration​
The configuration of the Solr sink connector has the following properties.
Property​
Name | Type | Required | Default | Description |
---|---|---|---|---|
solrUrl | String | true | " " (empty string) | Example localhost:2181,localhost:2182/chroot Example localhost:8983/solr |
solrMode | String | true | SolrCloud | The client mode when interacting with the Solr cluster. Below are the available options: |
solrCollection | String | true | " " (empty string) | Solr collection name to which records need to be written. |
solrCommitWithinMs | int | false | 10 | The time within million seconds for Solr updating commits. |
username | String | false | " " (empty string) | The username for basic authentication. Note: usename is case-sensitive. |
password | String | false | " " (empty string) | The password for basic authentication. Note: password is case-sensitive. |
Example​
Before using the Solr sink connector, you need to create a configuration file through one of the following methods.
-
JSON
{
"configs": {
"solrUrl": "localhost:2181,localhost:2182/chroot",
"solrMode": "SolrCloud",
"solrCollection": "techproducts",
"solrCommitWithinMs": 100,
"username": "fakeuser",
"password": "fake@123"
}
} -
YAML
configs:
solrUrl: "localhost:2181,localhost:2182/chroot"
solrMode: "SolrCloud"
solrCollection: "techproducts"
solrCommitWithinMs: 100
username: "fakeuser"
password: "fake@123"