Consume
yaml
type: "io.kestra.plugin.pulsar.consume"Examples
yaml
id: pulsar_consume
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.pulsar.Consume
uri: pulsar://localhost:26650
topic: test_kestra
deserializer: JSON
subscriptionName: kestra_flow
Properties
deserializer *Requiredstring
Default
STRING Possible Values
STRINGJSONBYTESsubscriptionName *Requiredstring
topic *Requiredobject
uri *Requiredstring
authenticationToken string
consumerName string
consumerProperties object
SubType string
encryptionKey string
initialPosition string
Default
Earliest Possible Values
LatestEarliestmaxDuration string
Format
durationmaxRecords integerstring
pollDuration string
Default
PT2S Format
durationschemaString string
schemaType string
Default
NONE Possible Values
NONEAVROJSONsubscriptionType string
Default
Exclusive Possible Values
ExclusiveSharedFailoverKey_SharedtlsOptions Non-dynamicAbstractPulsarConnection-TlsOptions
Outputs
messagesCount integer
uri string
Format
uri