Consume

Consume
Certified
Consume messages from Pulsar topics

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

encryptionKey string

initialPosition string

DefaultEarliest

Possible Values

LatestEarliest

maxDuration string

maxRecords integerstring

pluginDefaultsRef string

pollDuration string

DefaultPT2S

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

DocumentDB

Tasks that manage DocumentDB collections with MongoDB-compatible insert, query, update, and delete operations.

Data

Modal

Tasks that run Modal workflows via the Modal CLI.

DataInfrastructure

ConsumeCertifiedConsume messages from Pulsar topics

More Plugins in this Category

DocumentDB

Modal

Consume
Certified
Consume messages from Pulsar topics