VERSION

Features

  • Use Solr sink connector to sync data from Pulsar

Tags

Pulsar IO

Solr

Sink

Enterprise Support

StreamNative supported

Author

ASF

Solr Sink

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)
  • Comma-separated zookeeper hosts with chroot used in the SolrCloud mode.
    Example
    localhost:2181,localhost:2182/chroot

  • URL to connect to Solr used in standalone mode.
    Example
    localhost:8983/solr
  • solrMode String true SolrCloud The client mode when interacting with the Solr cluster.

    Below are the available options:
  • Standalone
  • SolrCloud
  • 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

      {
          "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"
      }