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 *string

DefaultSTRING

Possible Values

STRINGJSONBYTES

topic *object

uri *string

authenticationToken string

maxDuration string

Formatduration

maxRecords integerstring

messageId string

pollDuration string

DefaultPT2S

Formatduration

schemaString string

schemaType string

DefaultNONE

Possible Values

NONEAVROJSON

since string

Formatduration

tlsOptions

Definitions

io.kestra.plugin.pulsar.AbstractPulsarConnection-TlsOptions

castring

certstring

keystring

Outputs

messagesCount integer

uri string

Formaturi

AMQP

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time).

Messaging