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 c00aeeadda Docs sync done from apache/pulsar(#a1aa18f)
c00aeeadda is described below
commit c00aeeadda2a487d6672cd22b1a9409962760c85
Author: Pulsar Site Updater <[email protected]>
AuthorDate: Sun Apr 24 06:03:30 2022 +0000
Docs sync done from apache/pulsar(#a1aa18f)
---
site2/docs/client-libraries-java.md | 16 ++++++++++++++++
site2/website-next/docs/client-libraries-java.md | 18 ++++++++++++++++++
.../version-2.1.1-incubating/client-libraries-java.md | 18 ++++++++++++++++++
.../version-2.2.0/client-libraries-java.md | 18 ++++++++++++++++++
.../version-2.3.0/client-libraries-java.md | 18 ++++++++++++++++++
.../version-2.3.2/client-libraries-java.md | 18 ++++++++++++++++++
6 files changed, 106 insertions(+)
diff --git a/site2/docs/client-libraries-java.md
b/site2/docs/client-libraries-java.md
index e640b33216..13205461f7 100644
--- a/site2/docs/client-libraries-java.md
+++ b/site2/docs/client-libraries-java.md
@@ -1123,6 +1123,22 @@ pulsarClient.newReader()
Total hash range size is 65536, so the max end of the range should be less
than or equal to 65535.
+### Configure chunking
+
+Configuring chuncking for readers is similar to that for consumers. See
[configure chunking for consumers](#configure-chunking) for more information.
+
+The following is an example of how to configure message chunking for a reader.
+
+```java
+Reader<byte[]> reader = pulsarClient.newReader()
+ .topic(topicName)
+ .startMessageId(MessageId.earliest)
+ .maxPendingChunkedMessage(12)
+ .autoAckOldestChunkedMessageOnQueueFull(true)
+ .expireTimeOfIncompleteChunkedMessage(12, TimeUnit.MILLISECONDS)
+ .create();
+```
+
## TableView
The TableView interface serves an encapsulated access pattern, providing a
continuously updated key-value map view of the compacted topic data. Messages
without keys will be ignored.
diff --git a/site2/website-next/docs/client-libraries-java.md
b/site2/website-next/docs/client-libraries-java.md
index bec42fbd35..f4f6643b27 100644
--- a/site2/website-next/docs/client-libraries-java.md
+++ b/site2/website-next/docs/client-libraries-java.md
@@ -1282,6 +1282,24 @@ pulsarClient.newReader()
Total hash range size is 65536, so the max end of the range should be less
than or equal to 65535.
+### Configure chunking
+
+Configuring chuncking for readers is similar to that for consumers. See
[configure chunking for consumers](#configure-chunking) for more information.
+
+The following is an example of how to configure message chunking for a reader.
+
+```java
+
+Reader<byte[]> reader = pulsarClient.newReader()
+ .topic(topicName)
+ .startMessageId(MessageId.earliest)
+ .maxPendingChunkedMessage(12)
+ .autoAckOldestChunkedMessageOnQueueFull(true)
+ .expireTimeOfIncompleteChunkedMessage(12, TimeUnit.MILLISECONDS)
+ .create();
+
+```
+
## TableView
The TableView interface serves an encapsulated access pattern, providing a
continuously updated key-value map view of the compacted topic data. Messages
without keys will be ignored.
diff --git
a/site2/website-next/versioned_docs/version-2.1.1-incubating/client-libraries-java.md
b/site2/website-next/versioned_docs/version-2.1.1-incubating/client-libraries-java.md
index bec42fbd35..f4f6643b27 100644
---
a/site2/website-next/versioned_docs/version-2.1.1-incubating/client-libraries-java.md
+++
b/site2/website-next/versioned_docs/version-2.1.1-incubating/client-libraries-java.md
@@ -1282,6 +1282,24 @@ pulsarClient.newReader()
Total hash range size is 65536, so the max end of the range should be less
than or equal to 65535.
+### Configure chunking
+
+Configuring chuncking for readers is similar to that for consumers. See
[configure chunking for consumers](#configure-chunking) for more information.
+
+The following is an example of how to configure message chunking for a reader.
+
+```java
+
+Reader<byte[]> reader = pulsarClient.newReader()
+ .topic(topicName)
+ .startMessageId(MessageId.earliest)
+ .maxPendingChunkedMessage(12)
+ .autoAckOldestChunkedMessageOnQueueFull(true)
+ .expireTimeOfIncompleteChunkedMessage(12, TimeUnit.MILLISECONDS)
+ .create();
+
+```
+
## TableView
The TableView interface serves an encapsulated access pattern, providing a
continuously updated key-value map view of the compacted topic data. Messages
without keys will be ignored.
diff --git
a/site2/website-next/versioned_docs/version-2.2.0/client-libraries-java.md
b/site2/website-next/versioned_docs/version-2.2.0/client-libraries-java.md
index bec42fbd35..f4f6643b27 100644
--- a/site2/website-next/versioned_docs/version-2.2.0/client-libraries-java.md
+++ b/site2/website-next/versioned_docs/version-2.2.0/client-libraries-java.md
@@ -1282,6 +1282,24 @@ pulsarClient.newReader()
Total hash range size is 65536, so the max end of the range should be less
than or equal to 65535.
+### Configure chunking
+
+Configuring chuncking for readers is similar to that for consumers. See
[configure chunking for consumers](#configure-chunking) for more information.
+
+The following is an example of how to configure message chunking for a reader.
+
+```java
+
+Reader<byte[]> reader = pulsarClient.newReader()
+ .topic(topicName)
+ .startMessageId(MessageId.earliest)
+ .maxPendingChunkedMessage(12)
+ .autoAckOldestChunkedMessageOnQueueFull(true)
+ .expireTimeOfIncompleteChunkedMessage(12, TimeUnit.MILLISECONDS)
+ .create();
+
+```
+
## TableView
The TableView interface serves an encapsulated access pattern, providing a
continuously updated key-value map view of the compacted topic data. Messages
without keys will be ignored.
diff --git
a/site2/website-next/versioned_docs/version-2.3.0/client-libraries-java.md
b/site2/website-next/versioned_docs/version-2.3.0/client-libraries-java.md
index bec42fbd35..f4f6643b27 100644
--- a/site2/website-next/versioned_docs/version-2.3.0/client-libraries-java.md
+++ b/site2/website-next/versioned_docs/version-2.3.0/client-libraries-java.md
@@ -1282,6 +1282,24 @@ pulsarClient.newReader()
Total hash range size is 65536, so the max end of the range should be less
than or equal to 65535.
+### Configure chunking
+
+Configuring chuncking for readers is similar to that for consumers. See
[configure chunking for consumers](#configure-chunking) for more information.
+
+The following is an example of how to configure message chunking for a reader.
+
+```java
+
+Reader<byte[]> reader = pulsarClient.newReader()
+ .topic(topicName)
+ .startMessageId(MessageId.earliest)
+ .maxPendingChunkedMessage(12)
+ .autoAckOldestChunkedMessageOnQueueFull(true)
+ .expireTimeOfIncompleteChunkedMessage(12, TimeUnit.MILLISECONDS)
+ .create();
+
+```
+
## TableView
The TableView interface serves an encapsulated access pattern, providing a
continuously updated key-value map view of the compacted topic data. Messages
without keys will be ignored.
diff --git
a/site2/website-next/versioned_docs/version-2.3.2/client-libraries-java.md
b/site2/website-next/versioned_docs/version-2.3.2/client-libraries-java.md
index bec42fbd35..f4f6643b27 100644
--- a/site2/website-next/versioned_docs/version-2.3.2/client-libraries-java.md
+++ b/site2/website-next/versioned_docs/version-2.3.2/client-libraries-java.md
@@ -1282,6 +1282,24 @@ pulsarClient.newReader()
Total hash range size is 65536, so the max end of the range should be less
than or equal to 65535.
+### Configure chunking
+
+Configuring chuncking for readers is similar to that for consumers. See
[configure chunking for consumers](#configure-chunking) for more information.
+
+The following is an example of how to configure message chunking for a reader.
+
+```java
+
+Reader<byte[]> reader = pulsarClient.newReader()
+ .topic(topicName)
+ .startMessageId(MessageId.earliest)
+ .maxPendingChunkedMessage(12)
+ .autoAckOldestChunkedMessageOnQueueFull(true)
+ .expireTimeOfIncompleteChunkedMessage(12, TimeUnit.MILLISECONDS)
+ .create();
+
+```
+
## TableView
The TableView interface serves an encapsulated access pattern, providing a
continuously updated key-value map view of the compacted topic data. Messages
without keys will be ignored.
