pyflink.datastream.connectors.pulsar.MessageDelayer#
- class MessageDelayer(_j_message_delayer)[source]#
A delayer for Pulsar broker passing the sent message to the downstream consumer. This is only works in
SubscriptionType.Sharedsubscription.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.