pulsar
TEMPORARILY REMOVED
Unfortunately due to issues with the client library the pulsar components have been removed until further notice. It is still possible to create custom benthos builds with them included. For more information follow https://github.com/benthosdev/benthos/issues/1184
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: 64
# All config fields, showing default valuesoutput:label: ""pulsar:url: ""topic: ""key: ""ordering_key: ""max_in_flight: 64auth:oauth2:enabled: falseaudience: ""issuer_url: ""private_key_file: ""token:enabled: falsetoken: ""
Fields​
url
​
A URL to connect to.
Type: string
# Examplesurl: pulsar://localhost:6650url: pulsar://pulsar.us-west.example.com:6650url: pulsar+ssl://pulsar.us-west.example.com:6651
topic
​
The topic to publish to.
Type: string
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: 64
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
auth.oauth2.audience
​
OAuth2 audience.
Type: string
Default: ""
auth.oauth2.issuer_url
​
OAuth2 issuer URL.
Type: string
Default: ""
auth.oauth2.private_key_file
​
The path to a file containing a 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
auth.token.token
​
Actual base64 encoded token.
Type: string
Default: ""