sink
Solr Sink
The Solr sink connector pulls messages from Pulsar topics and persists the messages to Solr collections.
Authored by
ASF
Support type
StreamNative
License
Apache License 2.0

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

NameTypeRequiredDefaultDescription
solrUrlStringtrue" " (empty string)<li>Comma-separated zookeeper hosts with chroot used in the SolrCloud mode. <br>Example<br>localhost:2181,localhost:2182/chroot <br><br><li>URL to connect to Solr used in standalone mode. <br>Example<br>localhost:8983/solr
solrModeStringtrueSolrCloudThe client mode when interacting with the Solr cluster. <br><br>Below are the available options:<br><li>Standalone<br><li> SolrCloud
solrCollectionStringtrue" " (empty string)Solr collection name to which records need to be written.
solrCommitWithinMsintfalse10The time within million seconds for Solr updating commits.
usernameStringfalse" " (empty string)The username for basic authentication.<br><br>Note: usename is case-sensitive.
passwordStringfalse" " (empty string)The password for basic authentication. <br><br>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

    {
        "solrUrl": "localhost:2181,localhost:2182/chroot",
        "solrMode": "SolrCloud",
        "solrCollection": "techproducts",
        "solrCommitWithinMs": 100,
        "username": "fakeuser",
        "password": "fake@123"
    }
    
  • YAML

    {
        solrUrl: "localhost:2181,localhost:2182/chroot"
        solrMode: "SolrCloud"
        solrCollection: "techproducts"
        solrCommitWithinMs: 100
        username: "fakeuser"
        password: "fake@123"
    }