momo-jun commented on code in PR #589:
URL: https://github.com/apache/pulsar-site/pull/589#discussion_r1209659451
##########
docs/client-libraries-producers.md:
##########
@@ -440,44 +389,31 @@ class MessageRouter : public MessageRoutingPolicy {
};
```
- </TabItem>
-</Tabs>
-````
-
With that implementation, you can send messages to partitioned topics as below.
-
-````mdx-code-block
-<Tabs groupId="lang-choice"
- defaultValue="Java"
- values={[{"label":"Java","value":"Java"},{"label":"C++","value":"C++"}]}>
-<TabItem value="Java">
-
-```java
-String pulsarBrokerRootUrl = "pulsar://localhost:6650";
-String topic = "persistent://my-tenant/my-cluster-my-namespace/my-topic";
-
-PulsarClient pulsarClient =
PulsarClient.builder().serviceUrl(pulsarBrokerRootUrl).build();
-Producer<byte[]> producer = pulsarClient.newProducer()
- .topic(topic)
- .messageRouter(new AlwaysTenRouter())
- .create();
-producer.send("Partitioned topic message".getBytes());
-```
-
- </TabItem>
-
-
-<TabItem value="C++">
-
```cpp
Producer producer;
Result result = client.createProducer(
- "persistent://public/default/my-topic",
+ "my-topic",
ProducerConfiguration().setMessageRouter(std::make_shared<MessageRouter>()),
producer);
Message msg = MessageBuilder().setContent("content").build();
result = producer.send(msg);
```
+ </TabItem>
+
+ <TabItem value="Go">
+
+ In the Go client, we can configure the customize message router by passing a
funciton.
Review Comment:
```suggestion
In the Go client, you can configure a customized message router by passing
a function.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
