pyflink.datastream.connectors.pulsar.TopicRoutingMode

class TopicRoutingMode(value)

The routing policy for choosing the desired topic by the given message.

Data:

ROUND_ROBIN:

The producer will publish messages across all partitions in a round-robin fashion to achieve maximum throughput. Please note that round-robin is not done per individual message but rather it’s set to the same boundary of batching delay, to ensure batching is effective.

Data:

MESSAGE_KEY_HASH:

If no key is provided, The partitioned producer will randomly pick one single topic partition and publish all the messages into that partition. If a key is provided on the message, the partitioned producer will hash the key and assign the message to a particular partition.

Data:

CUSTOM:

Use custom topic router implementation that will be called to determine the partition for a particular message.

Attributes

ROUND_ROBIN
MESSAGE_KEY_HASH
CUSTOM