pulsar

EXPERIMENTAL: This component is experimental and therefore subject to change or removal outside of major version releases.

Reads messages from an Apache Pulsar server.

Introduced in version 3.43.0.

# Config fields, showing default values
input:
label: ""
pulsar:
url: ""
topics: []
subscription_name: ""

Metadata#

This input adds the following metadata fields to each message:

- pulsar_key
- pulsar_topic
- All properties of the message

You can access these metadata fields using function interpolation.

Fields#

url#

A URL to connect to.

Type: string
Default: ""

# Examples
url: pulsar://localhost:6650
url: pulsar://pulsar.us-west.example.com:6650
url: pulsar+ssl://pulsar.us-west.example.com:6651

topics#

A list of topics to subscribe to.

Type: array
Default: []

subscription_name#

Specify the subscription name for this consumer.

Type: string
Default: ""