pyflink.datastream.connectors.pulsar.MessageDelayer

class MessageDelayer(_j_message_delayer)

A delayer for Pulsar broker passing the sent message to the downstream consumer. This is only works in SubscriptionType.Shared subscription.

Read delayed message delivery https://pulsar.apache.org/docs/en/next/concepts-messaging/#delayed-message-delivery for better understanding this feature.

Methods

fixed(duration)	All the messages should be consumed in a fixed duration.
never()	All the messages should be consumed immediately.