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
- Advanced
# Common config fields, showing default valuesoutput:label: ""pulsar:url: ""topic: ""key: ""ordering_key: ""max_in_flight: 1
# All config fields, showing default valuesoutput:label: ""pulsar:url: ""topic: ""key: ""ordering_key: ""max_in_flight: 1auth:oauth2:enabled: falseaudience: ""issuer_url: ""private_key_file: ""token:enabled: falsetoken: ""
Fields​
url
​
A URL to connect to.
Type: string
Default: ""
# Examplesurl: pulsar://localhost:6650url: pulsar://pulsar.us-west.example.com:6650url: 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
# Examplesenabled: 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
# Examplesenabled: true
auth.token.token
​
Actual base64 encoded token.
Type: string
Default: ""