Reader
yaml
type: "io.kestra.plugin.pulsar.reader"Examples
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
STRING Possible Values
STRINGJSONBYTEStopic *Requiredobject
uri *Requiredstring
authenticationToken string
maxDuration string
Format
durationmaxRecords integerstring
messageId string
pollDuration string
Default
PT2S Format
durationschemaString string
schemaType string
Default
NONE Possible Values
NONEAVROJSONsince string
Format
durationtlsOptions Non-dynamicAbstractPulsarConnection-TlsOptions
Outputs
messagesCount integer
uri string
Format
uri