pyflink.datastream.connectors.pulsar.SubscriptionType

class SubscriptionType(value)

Types of subscription supported by Pulsar.

Data

Exclusive:

There can be only 1 consumer on the same topic with the same subscription name.

Data

Shared:

Multiple consumer will be able to use the same subscription name and the messages will be dispatched according to a round-robin rotation between the connected consumers. In this mode, the consumption order is not guaranteed.

Data

Failover:

Multiple consumer will be able to use the same subscription name but only 1 consumer will receive the messages. If that consumer disconnects, one of the other connected consumers will start receiving messages. In failover mode, the consumption ordering is guaranteed. In case of partitioned topics, the ordering is guaranteed on a per-partition basis. The partitions assignments will be split across the available consumers. On each partition, at most one consumer will be active at a given point in time.

Data

Key_Shared:

Multiple consumer will be able to use the same subscription and all messages with the same key will be dispatched to only one consumer. Use ordering_key to overwrite the message key for message ordering.

Attributes

Exclusive
Shared
Failover
Key_Shared