Skip to main content

pulsar

EXPERIMENTAL

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

Write messages to an Apache Pulsar server.

Introduced in version 3.43.0.

# Common config fields, showing default values
output:
  label: ""
  pulsar:
    url: ""
    topic: ""
    key: ""
    ordering_key: ""
    max_in_flight: 1

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

topic​

A topic to publish to.

Type: string
Default: ""

key​

The key to publish messages with. This field supports interpolation functions.

Type: string
Default: ""

ordering_key​

The ordering key to publish messages with. This field supports interpolation functions.

Type: string
Default: ""

max_in_flight​

The maximum number of messages to have in flight at a given time. Increase this to improve throughput.

Type: int
Default: 1

auth​

Optional configuration of Pulsar authentication methods.

Type: object
Requires version 3.60.0 or newer

auth.oauth2​

Parameters for Pulsar OAuth2 authentication.

Type: object

auth.oauth2.enabled​

Whether OAuth2 is enabled.

Type: bool
Default: false 

# Examples


enabled: true

auth.oauth2.audience​

OAuth2 audience.

Type: string
Default: ""

auth.oauth2.issuer_url​

OAuth2 issuer URL.

Type: string
Default: ""

auth.oauth2.private_key_file​

File containing the private key.

Type: string
Default: ""

auth.token​

Parameters for Pulsar Token authentication.

Type: object

auth.token.enabled​

Whether Token Auth is enabled.

Type: bool
Default: false 

# Examples


enabled: true

auth.token.token​

Actual base64 encoded token.

Type: string
Default: ""