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

DefaultSTRING

Possible Values

STRINGJSONBYTES

subscriptionName *string

topic *object

uri *string

authenticationToken string

consumerName string

consumerProperties object

SubTypestring

encryptionKey string

initialPosition string

DefaultEarliest

Possible Values

LatestEarliest

maxDuration string

Formatduration

maxRecords integerstring

pollDuration string

DefaultPT2S

Formatduration

schemaString string

schemaType string

DefaultNONE

Possible Values

NONEAVROJSON

subscriptionType string

DefaultExclusive

Possible Values

ExclusiveSharedFailoverKey_Shared

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