You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/03/12 08:57:54 UTC
[pulsar] branch asf-site updated: Updated site at revision ff4db8d
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new d528bd7 Updated site at revision ff4db8d
d528bd7 is described below
commit d528bd74ca00f42f34655a1cf67336626a29cc99
Author: jenkins <bu...@apache.org>
AuthorDate: Tue Mar 12 08:57:46 2019 +0000
Updated site at revision ff4db8d
---
content/docs/en/next/adaptors-kafka.html | 2 +-
content/docs/en/next/adaptors-kafka/index.html | 2 +-
.../en/next/admin-api-non-persistent-topics.html | 2 +-
.../admin-api-non-persistent-topics/index.html | 2 +-
content/docs/fr/next/adaptors-kafka.html | 2 +-
content/docs/fr/next/adaptors-kafka/index.html | 2 +-
.../fr/next/admin-api-non-persistent-topics.html | 2 +-
.../admin-api-non-persistent-topics/index.html | 2 +-
content/docs/ja/next/adaptors-kafka.html | 2 +-
content/docs/ja/next/adaptors-kafka/index.html | 2 +-
.../ja/next/admin-api-non-persistent-topics.html | 2 +-
.../admin-api-non-persistent-topics/index.html | 2 +-
.../zh-CN/2.1.0-incubating/adaptors-spark.html | 2 +-
.../2.1.0-incubating/adaptors-spark/index.html | 2 +-
.../zh-CN/2.1.1-incubating/adaptors-spark.html | 2 +-
.../2.1.1-incubating/adaptors-spark/index.html | 2 +-
content/docs/zh-CN/2.2.0/adaptors-spark.html | 2 +-
content/docs/zh-CN/2.2.0/adaptors-spark/index.html | 2 +-
content/docs/zh-CN/2.2.1/adaptors-spark.html | 2 +-
content/docs/zh-CN/2.2.1/adaptors-spark/index.html | 2 +-
content/docs/zh-CN/adaptors-spark.html | 2 +-
content/docs/zh-CN/adaptors-spark/index.html | 2 +-
content/docs/zh-CN/next/adaptors-kafka.html | 2 +-
content/docs/zh-CN/next/adaptors-kafka/index.html | 2 +-
content/docs/zh-CN/next/adaptors-spark.html | 2 +-
content/docs/zh-CN/next/adaptors-spark/index.html | 2 +-
.../next/admin-api-non-persistent-topics.html | 2 +-
.../admin-api-non-persistent-topics/index.html | 2 +-
content/swagger/swagger.json | 48 +++++++++++-----------
29 files changed, 52 insertions(+), 52 deletions(-)
diff --git a/content/docs/en/next/adaptors-kafka.html b/content/docs/en/next/adaptors-kafka.html
index a88c35b..abce83c 100644
--- a/content/docs/en/next/adaptors-kafka.html
+++ b/content/docs/en/next/adaptors-kafka.html
@@ -197,7 +197,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/en/next/adaptors-kafka/index.html b/content/docs/en/next/adaptors-kafka/index.html
index a88c35b..abce83c 100644
--- a/content/docs/en/next/adaptors-kafka/index.html
+++ b/content/docs/en/next/adaptors-kafka/index.html
@@ -197,7 +197,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/en/next/admin-api-non-persistent-topics.html b/content/docs/en/next/admin-api-non-persistent-topics.html
index 253673c..9c48f7e 100644
--- a/content/docs/en/next/admin-api-non-persistent-topics.html
+++ b/content/docs/en/next/admin-api-non-persistent-topics.html
@@ -96,7 +96,7 @@ persisting messages.</p>
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/en/next/admin-api-non-persistent-topics/index.html b/content/docs/en/next/admin-api-non-persistent-topics/index.html
index 253673c..9c48f7e 100644
--- a/content/docs/en/next/admin-api-non-persistent-topics/index.html
+++ b/content/docs/en/next/admin-api-non-persistent-topics/index.html
@@ -96,7 +96,7 @@ persisting messages.</p>
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/fr/next/adaptors-kafka.html b/content/docs/fr/next/adaptors-kafka.html
index 3457091..22cfd11 100644
--- a/content/docs/fr/next/adaptors-kafka.html
+++ b/content/docs/fr/next/adaptors-kafka.html
@@ -190,7 +190,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/fr/next/adaptors-kafka/index.html b/content/docs/fr/next/adaptors-kafka/index.html
index 3457091..22cfd11 100644
--- a/content/docs/fr/next/adaptors-kafka/index.html
+++ b/content/docs/fr/next/adaptors-kafka/index.html
@@ -190,7 +190,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/fr/next/admin-api-non-persistent-topics.html b/content/docs/fr/next/admin-api-non-persistent-topics.html
index aecb962..91dbbaa 100644
--- a/content/docs/fr/next/admin-api-non-persistent-topics.html
+++ b/content/docs/fr/next/admin-api-non-persistent-topics.html
@@ -94,7 +94,7 @@
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/fr/next/admin-api-non-persistent-topics/index.html b/content/docs/fr/next/admin-api-non-persistent-topics/index.html
index aecb962..91dbbaa 100644
--- a/content/docs/fr/next/admin-api-non-persistent-topics/index.html
+++ b/content/docs/fr/next/admin-api-non-persistent-topics/index.html
@@ -94,7 +94,7 @@
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/ja/next/adaptors-kafka.html b/content/docs/ja/next/adaptors-kafka.html
index dde7ee4..6e8d754 100644
--- a/content/docs/ja/next/adaptors-kafka.html
+++ b/content/docs/ja/next/adaptors-kafka.html
@@ -190,7 +190,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/ja/next/adaptors-kafka/index.html b/content/docs/ja/next/adaptors-kafka/index.html
index dde7ee4..6e8d754 100644
--- a/content/docs/ja/next/adaptors-kafka/index.html
+++ b/content/docs/ja/next/adaptors-kafka/index.html
@@ -190,7 +190,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/ja/next/admin-api-non-persistent-topics.html b/content/docs/ja/next/admin-api-non-persistent-topics.html
index 07e5be7..56a4b9e 100644
--- a/content/docs/ja/next/admin-api-non-persistent-topics.html
+++ b/content/docs/ja/next/admin-api-non-persistent-topics.html
@@ -94,7 +94,7 @@
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/ja/next/admin-api-non-persistent-topics/index.html b/content/docs/ja/next/admin-api-non-persistent-topics/index.html
index 07e5be7..56a4b9e 100644
--- a/content/docs/ja/next/admin-api-non-persistent-topics/index.html
+++ b/content/docs/ja/next/admin-api-non-persistent-topics/index.html
@@ -94,7 +94,7 @@
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/zh-CN/2.1.0-incubating/adaptors-spark.html b/content/docs/zh-CN/2.1.0-incubating/adaptors-spark.html
index ce72e5e..7d4e2cf 100644
--- a/content/docs/zh-CN/2.1.0-incubating/adaptors-spark.html
+++ b/content/docs/zh-CN/2.1.0-incubating/adaptors-spark.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.0-incubating/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.0-incubating/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a hre [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.1.0-incubating/adaptors-spark/index.html b/content/docs/zh-CN/2.1.0-incubating/adaptors-spark/index.html
index ce72e5e..7d4e2cf 100644
--- a/content/docs/zh-CN/2.1.0-incubating/adaptors-spark/index.html
+++ b/content/docs/zh-CN/2.1.0-incubating/adaptors-spark/index.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.0-incubating/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.0-incubating/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a hre [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.1.1-incubating/adaptors-spark.html b/content/docs/zh-CN/2.1.1-incubating/adaptors-spark.html
index 975be92..cc945d2 100644
--- a/content/docs/zh-CN/2.1.1-incubating/adaptors-spark.html
+++ b/content/docs/zh-CN/2.1.1-incubating/adaptors-spark.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.1-incubating/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.1-incubating/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a hre [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.1.1-incubating/adaptors-spark/index.html b/content/docs/zh-CN/2.1.1-incubating/adaptors-spark/index.html
index 975be92..cc945d2 100644
--- a/content/docs/zh-CN/2.1.1-incubating/adaptors-spark/index.html
+++ b/content/docs/zh-CN/2.1.1-incubating/adaptors-spark/index.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">here</a>. 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.1-incubating/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.1-incubating/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a hre [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.2.0/adaptors-spark.html b/content/docs/zh-CN/2.2.0/adaptors-spark.html
index 9fdea63..a9fbfc2 100644
--- a/content/docs/zh-CN/2.2.0/adaptors-spark.html
+++ b/content/docs/zh-CN/2.2.0/adaptors-spark.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.2.0/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.2.0/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a href="#maven">Maven</a></ [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.2.0/adaptors-spark/index.html b/content/docs/zh-CN/2.2.0/adaptors-spark/index.html
index 9fdea63..a9fbfc2 100644
--- a/content/docs/zh-CN/2.2.0/adaptors-spark/index.html
+++ b/content/docs/zh-CN/2.2.0/adaptors-spark/index.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.2.0/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.2.0/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a href="#maven">Maven</a></ [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.2.1/adaptors-spark.html b/content/docs/zh-CN/2.2.1/adaptors-spark.html
index 0cc4db1..39ca57c 100644
--- a/content/docs/zh-CN/2.2.1/adaptors-spark.html
+++ b/content/docs/zh-CN/2.2.1/adaptors-spark.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.2.1/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.2.1/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a href="#maven">Maven</a></ [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/2.2.1/adaptors-spark/index.html b/content/docs/zh-CN/2.2.1/adaptors-spark/index.html
index 0cc4db1..39ca57c 100644
--- a/content/docs/zh-CN/2.2.1/adaptors-spark/index.html
+++ b/content/docs/zh-CN/2.2.1/adaptors-spark/index.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.2.1/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/2.2.1/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a href="#maven">Maven</a></ [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/adaptors-spark.html b/content/docs/zh-CN/adaptors-spark.html
index a012e29..9a56aa9 100644
--- a/content/docs/zh-CN/adaptors-spark.html
+++ b/content/docs/zh-CN/adaptors-spark.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a href="#maven">Maven</a></li><li><a hr [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/adaptors-spark/index.html b/content/docs/zh-CN/adaptors-spark/index.html
index a012e29..9a56aa9 100644
--- a/content/docs/zh-CN/adaptors-spark/index.html
+++ b/content/docs/zh-CN/adaptors-spark/index.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#prerequisites">Prerequisites</a><ul class="toc-headings"><li><a href="#maven">Maven</a></li><li><a hr [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/next/adaptors-kafka.html b/content/docs/zh-CN/next/adaptors-kafka.html
index 09649f7..6d516e8 100644
--- a/content/docs/zh-CN/next/adaptors-kafka.html
+++ b/content/docs/zh-CN/next/adaptors-kafka.html
@@ -190,7 +190,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/zh-CN/next/adaptors-kafka/index.html b/content/docs/zh-CN/next/adaptors-kafka/index.html
index 09649f7..6d516e8 100644
--- a/content/docs/zh-CN/next/adaptors-kafka/index.html
+++ b/content/docs/zh-CN/next/adaptors-kafka/index.html
@@ -190,7 +190,7 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>request.timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>retries</code></td><td style="text-align:left">Ignored</td><td style="text-align:left">Pulsar client retries with exponential backoff until the send timeout expires</td></tr>
<tr><td style="text-align:left"><code>send.buffer.bytes</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>timeout.ms</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>value.serializer</code></td><td style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
</tbody>
</table>
diff --git a/content/docs/zh-CN/next/adaptors-spark.html b/content/docs/zh-CN/next/adaptors-spark.html
index 07c117a..f2a23c8 100644
--- a/content/docs/zh-CN/next/adaptors-spark.html
+++ b/content/docs/zh-CN/next/adaptors-spark.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="例子"></a><a href="#例子" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1-2.09V6.25c [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/next/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/next/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#先决条件">先决条件</a><ul class="toc-headings"><li><a href="#maven">Maven</a></li><li><a href="#gra [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/next/adaptors-spark/index.html b/content/docs/zh-CN/next/adaptors-spark/index.html
index 07c117a..f2a23c8 100644
--- a/content/docs/zh-CN/next/adaptors-spark/index.html
+++ b/content/docs/zh-CN/next/adaptors-spark/index.html
@@ -109,7 +109,7 @@ JavaReceiverInputDStream<<span class="hljs-keyword">byte</span>[]> msgs =
.receiverStream(<span class="hljs-keyword">new</span> SparkStreamingPulsarReceiver(clientConf, consConf, url, topic, subs));
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="例子"></a><a href="#例子" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1-2.09V6.25c [...]
-<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 在此示例中, 将计算在接收的消息中包含字符串 "Pulsar" 的消息数。</p>
+<p>你可以在<a href="https://github.com/apache/pulsar/tree/master/tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/example/SparkStreamingPulsarReceiverExample.java">这里</a>找到一个完整的例子。 该示例会把接收的消息中包含字符串 "Pulsar" 的消息数计算出来。</p>
</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/next/adaptors-kafka"><span class="arrow-prev">← </span><span>Kafka 客户端 wrapper</span></a><a class="docs-next button" href="/docs/zh-CN/next/adaptors-storm"><span>Apache Storm</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#先决条件">先决条件</a><ul class="toc-headings"><li><a href="#maven">Maven</a></li><li><a href="#gra [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
diff --git a/content/docs/zh-CN/next/admin-api-non-persistent-topics.html b/content/docs/zh-CN/next/admin-api-non-persistent-topics.html
index eecaef2..03ee84f 100644
--- a/content/docs/zh-CN/next/admin-api-non-persistent-topics.html
+++ b/content/docs/zh-CN/next/admin-api-non-persistent-topics.html
@@ -94,7 +94,7 @@
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/docs/zh-CN/next/admin-api-non-persistent-topics/index.html b/content/docs/zh-CN/next/admin-api-non-persistent-topics/index.html
index eecaef2..03ee84f 100644
--- a/content/docs/zh-CN/next/admin-api-non-persistent-topics/index.html
+++ b/content/docs/zh-CN/next/admin-api-non-persistent-topics/index.html
@@ -94,7 +94,7 @@
<li><p><strong>type</strong>: This subscription type</p></li>
<li><p><strong>consumers</strong>: The list of connected consumers for this subscription</p></li>
<li><p><strong>consumerName</strong>: Internal identifier for this consumer, generated by the client library</p></li>
-<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value of 0 means the client library's queue is full and receive() isn't being called. A nonzero value means this consumer is ready to be dispatched messages.</p></li>
+<li><p><strong>availablePermits</strong>: The number of messages this consumer has space for in the client library's listen queue. A value less than 1 means the client library's queue is full and receive() isn't being called. A non-negative value means this consumer is ready to be dispatched messages.</p></li>
<li><p><strong>replication</strong>: This section gives the stats for cross-colo replication of this topic</p></li>
<li><p><strong>connected</strong>: Whether the outbound replicator is connected</p></li>
<li><p><strong>inboundConnection</strong>: The IP and port of the broker in the remote cluster's publisher connection to this broker</p></li>
diff --git a/content/swagger/swagger.json b/content/swagger/swagger.json
index 992ab6c..928ec09 100644
--- a/content/swagger/swagger.json
+++ b/content/swagger/swagger.json
@@ -6770,10 +6770,10 @@
"type" : "string"
}
},
- "connectedSince" : {
+ "clientVersion" : {
"type" : "string"
},
- "clientVersion" : {
+ "connectedSince" : {
"type" : "string"
},
"address" : {
@@ -7105,21 +7105,6 @@
"memory" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "underLoaded" : {
- "type" : "boolean"
- },
- "overLoaded" : {
- "type" : "boolean"
- },
- "loadReportType" : {
- "type" : "string"
- },
- "cpu" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "directMemory" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
"lastUpdate" : {
"type" : "integer",
"format" : "int64"
@@ -7131,6 +7116,21 @@
"msgThroughputOut" : {
"type" : "number",
"format" : "double"
+ },
+ "cpu" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "directMemory" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "underLoaded" : {
+ "type" : "boolean"
+ },
+ "overLoaded" : {
+ "type" : "boolean"
+ },
+ "loadReportType" : {
+ "type" : "string"
}
}
},
@@ -7293,10 +7293,10 @@
"producerName" : {
"type" : "string"
},
- "connectedSince" : {
+ "clientVersion" : {
"type" : "string"
},
- "clientVersion" : {
+ "connectedSince" : {
"type" : "string"
},
"address" : {
@@ -8007,10 +8007,10 @@
"producerName" : {
"type" : "string"
},
- "connectedSince" : {
+ "clientVersion" : {
"type" : "string"
},
- "clientVersion" : {
+ "connectedSince" : {
"type" : "string"
},
"address" : {
@@ -8112,11 +8112,11 @@
"ResourceUnit" : {
"type" : "object",
"properties" : {
- "resourceId" : {
- "type" : "string"
- },
"availableResource" : {
"$ref" : "#/definitions/ResourceDescription"
+ },
+ "resourceId" : {
+ "type" : "string"
}
}
},