Solr sink connector
note
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"