Uses of Interface
org.apache.flink.connector.pulsar.sink.writer.router.TopicRouter

Packages that use TopicRouter

Package	Description
org.apache.flink.connector.pulsar.sink
org.apache.flink.connector.pulsar.sink.writer
org.apache.flink.connector.pulsar.sink.writer.router

Uses of TopicRouter in org.apache.flink.connector.pulsar.sink

Methods in org.apache.flink.connector.pulsar.sink with parameters of type TopicRouter

Modifier and Type	Method and Description
PulsarSinkBuilder<IN>	PulsarSinkBuilder.setTopicRouter(TopicRouter<IN> topicRouter) Use a custom topic router instead predefine topic routing.

Uses of TopicRouter in org.apache.flink.connector.pulsar.sink.writer

Constructors in org.apache.flink.connector.pulsar.sink.writer with parameters of type TopicRouter

Constructor and Description
PulsarWriter(SinkConfiguration sinkConfiguration, PulsarSerializationSchema<IN> serializationSchema, TopicMetadataListener metadataListener, TopicRouter<IN> topicRouter, MessageDelayer<IN> messageDelayer, Sink.InitContext initContext) Constructor creating a Pulsar writer.

Uses of TopicRouter in org.apache.flink.connector.pulsar.sink.writer.router

Classes in org.apache.flink.connector.pulsar.sink.writer.router that implement TopicRouter

Modifier and Type	Class and Description
class	KeyHashTopicRouter<IN> If you choose the TopicRoutingMode.MESSAGE_KEY_HASH policy, we would use this implementation.
class	RoundRobinTopicRouter<IN> If you choose the TopicRoutingMode.ROUND_ROBIN policy, we would use this implementation.