This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new 90aa8cbdff0 Docs sync done from apache/pulsar(#29461bd)
90aa8cbdff0 is described below
commit 90aa8cbdff0036e13820b79f152ab38e0a7474e8
Author: Pulsar Site Updater <[email protected]>
AuthorDate: Wed Oct 26 18:01:50 2022 +0000
Docs sync done from apache/pulsar(#29461bd)
---
site2/website-next/docs/client-libraries-go.md | 28 ++++++++++++++++++++++++++
1 file changed, 28 insertions(+)
diff --git a/site2/website-next/docs/client-libraries-go.md
b/site2/website-next/docs/client-libraries-go.md
index 8ca9f269f5e..14b331409ce 100644
--- a/site2/website-next/docs/client-libraries-go.md
+++ b/site2/website-next/docs/client-libraries-go.md
@@ -204,6 +204,34 @@ for i := 0; i < 10; i++ {
}
```
+#### How to use chunking in producer
+
+```go
+client, err := pulsar.NewClient(pulsar.ClientOptions{
+ URL: serviceURL,
+})
+
+if err != nil {
+ log.Fatal(err)
+}
+defer client.Close()
+
+// The message chunking feature is OFF by default.
+// By default, a producer chunks the large message based on the max message
size (`maxMessageSize`) configured at the broker side (for example, 5MB).
+// Client can also configure the max chunked size using the producer
configuration `ChunkMaxMessageSize`.
+// Note: to enable chunking, you need to disable batching
(`DisableBatching=true`) concurrently.
+producer, err := client.CreateProducer(pulsar.ProducerOptions{
+ Topic: "my-topic",
+ DisableBatching: true,
+ EnableChunking: true,
+})
+
+if err != nil {
+ log.Fatal(err)
+}
+defer producer.Close()
+```
+
#### How to use schema interface in producer
```go
