Reader
Certified
Read messages from Pulsar topics without subscription
Reader
Certified
Read messages from Pulsar topics without subscription
yaml
type: io.kestra.plugin.pulsar.ReaderExamples
yaml
id: pulsar_reader
namespace: company.team
tasks:
- id: reader
type: io.kestra.plugin.pulsar.Reader
uri: pulsar://localhost:26650
topic: test_kestra
deserializer: JSON
Properties
deserializer *Requiredstring
Default
STRINGPossible Values
STRINGJSONBYTEStopic *Requiredobject
uri *Requiredstring
authenticationToken string
maxDuration string
maxRecords integerstring
messageId string
pollDuration string
Default
PT2SschemaString string
schemaType string
Default
NONEPossible Values
NONEAVROJSONsince string
tlsOptions Non-dynamic
Definitions
io.kestra.plugin.pulsar.AbstractPulsarConnection-TlsOptions
castring
certstring
keystring
Outputs
messagesCount integer
uri string
Format
uri
