pyflink.datastream.connectors.pulsar.TopicRoutingMode#
- class TopicRoutingMode(value)[source]#
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