[FEATURE] Use custom MessageRouting to publish messages to partition topics about pulsar-flink HOT 6 CLOSED

@jianyun8023 would you please help answer this question and add related doc?

from pulsar-flink.

@jianyun8023 would you please help answer this question and add related doc?

Okay, the documentation for the connector is really not enough, I will add the documentation.

from pulsar-flink.

It does not currently support setting messageRoutingMode(MessageRoutingMode.SinglePartition) to select the partition to which the message is sent.

String pulsarBrokerRootUrl = "pulsar://localhost:6650";
String topic = "persistent://my-tenant/my-namespace/my-topic";

PulsarClient pulsarClient = PulsarClient.builder().serviceUrl(pulsarBrokerRootUrl).build();
Producer<byte[]> producer = pulsarClient.newProducer()
        .topic(topic)
        .messageRoutingMode(MessageRoutingMode.SinglePartition)
        .create();
producer.send("Partitioned topic message".getBytes());

from pulsar-flink.

@jianyun8023 if this is supported, we should update the readme and docs

from pulsar-flink.

Custom MessageRouting is currently not supported. Thank you for your suggestion. Support will be added in subsequent versions.

from pulsar-flink.

in #209, Because upsert requires a message router for the key, So this feature is supported by the way.

from pulsar-flink.