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/09/01 09:05:33 UTC
[pulsar] branch asf-site updated: Updated site at revision f1eae9c
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 4b86484 Updated site at revision f1eae9c
4b86484 is described below
commit 4b8648415f2fb8fafa5e5a09b5592b0926ee44ff
Author: jenkins <bu...@apache.org>
AuthorDate: Sun Sep 1 09:05:21 2019 +0000
Updated site at revision f1eae9c
---
content/docs/en/next/client-libraries-java.html | 31 ++++++++++++++-
.../docs/en/next/client-libraries-java/index.html | 31 ++++++++++++++-
content/docs/fr/next/client-libraries-java.html | 12 +++++-
.../docs/fr/next/client-libraries-java/index.html | 12 +++++-
content/docs/ja/next/client-libraries-java.html | 10 ++++-
.../docs/ja/next/client-libraries-java/index.html | 10 ++++-
content/docs/zh-CN/concepts-tiered-storage.html | 2 +-
.../docs/zh-CN/concepts-tiered-storage/index.html | 2 +-
content/docs/zh-CN/next/client-libraries-java.html | 12 +++++-
.../zh-CN/next/client-libraries-java/index.html | 12 +++++-
.../docs/zh-CN/next/concepts-tiered-storage.html | 6 +--
.../zh-CN/next/concepts-tiered-storage/index.html | 6 +--
content/swagger/2.5.0-SNAPSHOT/swagger.json | 46 +++++++++++-----------
.../swagger/2.5.0-SNAPSHOT/swaggerfunctions.json | 46 +++++++++++-----------
content/swagger/swagger.json | 46 +++++++++++-----------
content/swagger/swaggerfunctions.json | 46 +++++++++++-----------
16 files changed, 218 insertions(+), 112 deletions(-)
diff --git a/content/docs/en/next/client-libraries-java.html b/content/docs/en/next/client-libraries-java.html
index bd08a83..7ec9ca2 100644
--- a/content/docs/en/next/client-libraries-java.html
+++ b/content/docs/en/next/client-libraries-java.html
@@ -138,6 +138,34 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="default-broker-urls-for-standalone-clusters"></a><a href="#default-broker-urls-for-standalone-clusters" 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-1v1h [...]
<p>If you're running a cluster in <a href="/docs/en/next/standalone">standalone mode</a>, the broker will be available at the <code>pulsar://localhost:6650</code> URL by default.</p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<table>
+<thead>
+<tr><th>Type</th><th>Name</th><th>Description</th><th>Default</th></tr>
+</thead>
+<tbody>
+<tr><td>String</td><td><code>serviceUrl</code></td><td>Service URL provider for Pulsar service</td><td>None</td></tr>
+<tr><td>String</td><td><code>authPluginClassName</code></td><td>Name of the authentication plugin</td><td>None</td></tr>
+<tr><td>String</td><td><code>authParams</code></td><td>String represents parameters for the authentication plugin <br><strong>Example</strong><br> key1:val1,key2:val2</td><td>None</td></tr>
+<tr><td>long</td><td><code>operationTimeoutMs</code></td><td>Operation timeout</td><td>30000</td></tr>
+<tr><td>long</td><td><code>statsIntervalSeconds</code></td><td>Interval between each stat info<br>Stats is activated with positive <code>statsInterval</code><br><code>statsIntervalSeconds</code> should be set to 1 second at least</td><td>60</td></tr>
+<tr><td>int</td><td><code>numIoThreads</code></td><td>Number of threads used for handling connections to brokers</td><td>1</td></tr>
+<tr><td>int</td><td><code>numListenerThreads</code></td><td>Number of threads used for handling message listeners</td><td>1</td></tr>
+<tr><td>boolean</td><td><code>useTcpNoDelay</code></td><td>Whether to use TCP no-delay flag on the connection to disable Nagle algorithm</td><td>true</td></tr>
+<tr><td>boolean</td><td><code>useTls</code></td><td>Whether to use TLS encryption on the connection</td><td>false</td></tr>
+<tr><td>string</td><td><code>tlsTrustCertsFilePath</code></td><td>Path to the trusted TLS certificate file</td><td>None</td></tr>
+<tr><td>boolean</td><td><code>tlsAllowInsecureConnection</code></td><td>Whether the Pulsar client accepts untrusted TLS certificate from broker</td><td>false</td></tr>
+<tr><td>boolean</td><td><code>tlsHostnameVerificationEnable</code></td><td>Whether to enable TLS hostname verification</td><td>false</td></tr>
+<tr><td>int</td><td><code>concurrentLookupRequest</code></td><td>Number of concurrent lookup requests allowed to send on each broker connection to prevent overload on broker</td><td>5000</td></tr>
+<tr><td>int</td><td><code>maxLookupRequest</code></td><td>Maximum number of lookup requests allowed on each broker connection to prevent overload on broker</td><td>50000</td></tr>
+<tr><td>int</td><td><code>maxNumberOfRejectedRequestPerConnection</code></td><td>Maximum number of rejected requests of a broker in a certain time frame (30 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker</td><td>50</td></tr>
+<tr><td>int</td><td><code>keepAliveIntervalSeconds</code></td><td>Seconds of keeping alive interval for each client broker connection</td><td>30</td></tr>
+<tr><td>int</td><td><code>connectionTimeoutMs</code></td><td>Duration of waiting for a connection to a broker to be established <br>If the duration passes without a response from a broker, the connection attempt is dropped</td><td>10000</td></tr>
+<tr><td>int</td><td><code>requestTimeoutMs</code></td><td>Maximum duration for completing a request</td><td>60000</td></tr>
+<tr><td>int</td><td><code>defaultBackoffIntervalNanos</code></td><td>Default duration for a backoff interval</td><td>TimeUnit.MILLISECONDS.toNanos(100);</td></tr>
+<tr><td>long</td><td><code>maxBackoffIntervalNanos</code></td><td>Maximum duration for a backoff interval</td><td>TimeUnit.SECONDS.toNanos(30)</td></tr>
+</tbody>
+</table>
<p>Check out the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
class for a full listing of configurable parameters.</p>
<blockquote>
@@ -176,7 +204,8 @@ client.close();
</code></pre>
</blockquote>
<h3><a class="anchor" aria-hidden="true" id="configuring-producers"></a><a href="#configuring-producers" 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 [...]
-<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set. For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set.</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
diff --git a/content/docs/en/next/client-libraries-java/index.html b/content/docs/en/next/client-libraries-java/index.html
index bd08a83..7ec9ca2 100644
--- a/content/docs/en/next/client-libraries-java/index.html
+++ b/content/docs/en/next/client-libraries-java/index.html
@@ -138,6 +138,34 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="default-broker-urls-for-standalone-clusters"></a><a href="#default-broker-urls-for-standalone-clusters" 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-1v1h [...]
<p>If you're running a cluster in <a href="/docs/en/next/standalone">standalone mode</a>, the broker will be available at the <code>pulsar://localhost:6650</code> URL by default.</p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<table>
+<thead>
+<tr><th>Type</th><th>Name</th><th>Description</th><th>Default</th></tr>
+</thead>
+<tbody>
+<tr><td>String</td><td><code>serviceUrl</code></td><td>Service URL provider for Pulsar service</td><td>None</td></tr>
+<tr><td>String</td><td><code>authPluginClassName</code></td><td>Name of the authentication plugin</td><td>None</td></tr>
+<tr><td>String</td><td><code>authParams</code></td><td>String represents parameters for the authentication plugin <br><strong>Example</strong><br> key1:val1,key2:val2</td><td>None</td></tr>
+<tr><td>long</td><td><code>operationTimeoutMs</code></td><td>Operation timeout</td><td>30000</td></tr>
+<tr><td>long</td><td><code>statsIntervalSeconds</code></td><td>Interval between each stat info<br>Stats is activated with positive <code>statsInterval</code><br><code>statsIntervalSeconds</code> should be set to 1 second at least</td><td>60</td></tr>
+<tr><td>int</td><td><code>numIoThreads</code></td><td>Number of threads used for handling connections to brokers</td><td>1</td></tr>
+<tr><td>int</td><td><code>numListenerThreads</code></td><td>Number of threads used for handling message listeners</td><td>1</td></tr>
+<tr><td>boolean</td><td><code>useTcpNoDelay</code></td><td>Whether to use TCP no-delay flag on the connection to disable Nagle algorithm</td><td>true</td></tr>
+<tr><td>boolean</td><td><code>useTls</code></td><td>Whether to use TLS encryption on the connection</td><td>false</td></tr>
+<tr><td>string</td><td><code>tlsTrustCertsFilePath</code></td><td>Path to the trusted TLS certificate file</td><td>None</td></tr>
+<tr><td>boolean</td><td><code>tlsAllowInsecureConnection</code></td><td>Whether the Pulsar client accepts untrusted TLS certificate from broker</td><td>false</td></tr>
+<tr><td>boolean</td><td><code>tlsHostnameVerificationEnable</code></td><td>Whether to enable TLS hostname verification</td><td>false</td></tr>
+<tr><td>int</td><td><code>concurrentLookupRequest</code></td><td>Number of concurrent lookup requests allowed to send on each broker connection to prevent overload on broker</td><td>5000</td></tr>
+<tr><td>int</td><td><code>maxLookupRequest</code></td><td>Maximum number of lookup requests allowed on each broker connection to prevent overload on broker</td><td>50000</td></tr>
+<tr><td>int</td><td><code>maxNumberOfRejectedRequestPerConnection</code></td><td>Maximum number of rejected requests of a broker in a certain time frame (30 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker</td><td>50</td></tr>
+<tr><td>int</td><td><code>keepAliveIntervalSeconds</code></td><td>Seconds of keeping alive interval for each client broker connection</td><td>30</td></tr>
+<tr><td>int</td><td><code>connectionTimeoutMs</code></td><td>Duration of waiting for a connection to a broker to be established <br>If the duration passes without a response from a broker, the connection attempt is dropped</td><td>10000</td></tr>
+<tr><td>int</td><td><code>requestTimeoutMs</code></td><td>Maximum duration for completing a request</td><td>60000</td></tr>
+<tr><td>int</td><td><code>defaultBackoffIntervalNanos</code></td><td>Default duration for a backoff interval</td><td>TimeUnit.MILLISECONDS.toNanos(100);</td></tr>
+<tr><td>long</td><td><code>maxBackoffIntervalNanos</code></td><td>Maximum duration for a backoff interval</td><td>TimeUnit.SECONDS.toNanos(30)</td></tr>
+</tbody>
+</table>
<p>Check out the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
class for a full listing of configurable parameters.</p>
<blockquote>
@@ -176,7 +204,8 @@ client.close();
</code></pre>
</blockquote>
<h3><a class="anchor" aria-hidden="true" id="configuring-producers"></a><a href="#configuring-producers" 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 [...]
-<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set. For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set.</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
diff --git a/content/docs/fr/next/client-libraries-java.html b/content/docs/fr/next/client-libraries-java.html
index b061b1c..42106dd 100644
--- a/content/docs/fr/next/client-libraries-java.html
+++ b/content/docs/fr/next/client-libraries-java.html
@@ -138,6 +138,13 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="url-par-defaut-pour-les-clusters-en-mode-standalone"></a><a href="#url-par-defaut-pour-les-clusters-en-mode-standalone" 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 [...]
<p>Si vous exécutez un cluster en mode <a href="/docs/fr/next/standalone">standalone</a>, le broker sera disponible à l'URL <code>pulsar://localhost:6650</code> par défaut.</p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<p>| Type | Name | Description | Default |---|---|---|--- String | <code>serviceUrl</code> |Service URL provider for Pulsar service | None String | <code>authPluginClassName</code> | Name of the authentication plugin | None String | <code>authParams</code> | String represents parameters for the authentication plugin<br>
+<strong>Example</strong> <br>
+key1:val1,key2:val2|None long|<code>operationTimeoutMs</code>|Operation timeout |30000 long|<code>statsIntervalSeconds</code>|Interval between each stat info<br>
+Stats is activated with positive <code>statsInterval</code> <br>
+<code>statsIntervalSeconds</code> should be set to 1 second at least |60 int|<code>numIoThreads</code>| Number of threads used for handling connections to brokers | 1 int|<code>numListenerThreads</code>|Number of threads used for handling message listeners | 1 boolean|<code>useTcpNoDelay</code>|Whether to use TCP no-delay flag on the connection to disable Nagle algorithm |true boolean |<code>useTls</code> |Whether to use TLS encryption on the connection| false string | <code>tlsTrustCert [...]
+If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|<code>requestTimeoutMs</code>|Maximum duration for completing a request |60000 int|<code>defaultBackoffIntervalNanos</code>| Default duration for a backoff interval | TimeUnit.MILLISECONDS.toNanos(100); long|<code>maxBackoffIntervalNanos</code>|Maximum duration for a backoff interval|TimeUnit.SECONDS.toNanos(30)</p>
<p>Consultez la javadoc pour la classe <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
pour une liste complète des paramètres configurables.</p>
<blockquote>
@@ -178,8 +185,9 @@ Les opérations de fermeture peuvent également être asynchrones :
})<span class="hljs-comment">;</span>
</code></pre>
<h3><a class="anchor" aria-hidden="true" id="configuration-des-producteurs"></a><a href="#configuration-des-producteurs" 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 [...]
-<p>Si vous instanciez un objet <code>Producer</code> en spécifiant seulement un nom detopic, comme dans l'exemple ci-dessus, le producteur utilisera la configuration par défaut. Pour utiliser une configuration différente de celle par défaut, il existe une variété de paramètres configurables que vous pouvez définir. Pour une liste complète, voir la javadoc pour la classe <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
- . Here's an example:</p>
+<p>Si vous instanciez un objet <code>Producer</code> en spécifiant seulement un nom detopic, comme dans l'exemple ci-dessus, le producteur utilisera la configuration par défaut. Pour utiliser une configuration différente de celle par défaut, il existe une variété de paramètres configurables que vous pouvez définir.</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+ class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
.batchingMaxPublishDelay(<span class="hljs-number">10</span>, TimeUnit.MILLISECONDS)
diff --git a/content/docs/fr/next/client-libraries-java/index.html b/content/docs/fr/next/client-libraries-java/index.html
index b061b1c..42106dd 100644
--- a/content/docs/fr/next/client-libraries-java/index.html
+++ b/content/docs/fr/next/client-libraries-java/index.html
@@ -138,6 +138,13 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="url-par-defaut-pour-les-clusters-en-mode-standalone"></a><a href="#url-par-defaut-pour-les-clusters-en-mode-standalone" 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 [...]
<p>Si vous exécutez un cluster en mode <a href="/docs/fr/next/standalone">standalone</a>, le broker sera disponible à l'URL <code>pulsar://localhost:6650</code> par défaut.</p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<p>| Type | Name | Description | Default |---|---|---|--- String | <code>serviceUrl</code> |Service URL provider for Pulsar service | None String | <code>authPluginClassName</code> | Name of the authentication plugin | None String | <code>authParams</code> | String represents parameters for the authentication plugin<br>
+<strong>Example</strong> <br>
+key1:val1,key2:val2|None long|<code>operationTimeoutMs</code>|Operation timeout |30000 long|<code>statsIntervalSeconds</code>|Interval between each stat info<br>
+Stats is activated with positive <code>statsInterval</code> <br>
+<code>statsIntervalSeconds</code> should be set to 1 second at least |60 int|<code>numIoThreads</code>| Number of threads used for handling connections to brokers | 1 int|<code>numListenerThreads</code>|Number of threads used for handling message listeners | 1 boolean|<code>useTcpNoDelay</code>|Whether to use TCP no-delay flag on the connection to disable Nagle algorithm |true boolean |<code>useTls</code> |Whether to use TLS encryption on the connection| false string | <code>tlsTrustCert [...]
+If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|<code>requestTimeoutMs</code>|Maximum duration for completing a request |60000 int|<code>defaultBackoffIntervalNanos</code>| Default duration for a backoff interval | TimeUnit.MILLISECONDS.toNanos(100); long|<code>maxBackoffIntervalNanos</code>|Maximum duration for a backoff interval|TimeUnit.SECONDS.toNanos(30)</p>
<p>Consultez la javadoc pour la classe <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
pour une liste complète des paramètres configurables.</p>
<blockquote>
@@ -178,8 +185,9 @@ Les opérations de fermeture peuvent également être asynchrones :
})<span class="hljs-comment">;</span>
</code></pre>
<h3><a class="anchor" aria-hidden="true" id="configuration-des-producteurs"></a><a href="#configuration-des-producteurs" 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 [...]
-<p>Si vous instanciez un objet <code>Producer</code> en spécifiant seulement un nom detopic, comme dans l'exemple ci-dessus, le producteur utilisera la configuration par défaut. Pour utiliser une configuration différente de celle par défaut, il existe une variété de paramètres configurables que vous pouvez définir. Pour une liste complète, voir la javadoc pour la classe <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
- . Here's an example:</p>
+<p>Si vous instanciez un objet <code>Producer</code> en spécifiant seulement un nom detopic, comme dans l'exemple ci-dessus, le producteur utilisera la configuration par défaut. Pour utiliser une configuration différente de celle par défaut, il existe une variété de paramètres configurables que vous pouvez définir.</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+ class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
.batchingMaxPublishDelay(<span class="hljs-number">10</span>, TimeUnit.MILLISECONDS)
diff --git a/content/docs/ja/next/client-libraries-java.html b/content/docs/ja/next/client-libraries-java.html
index 33b75f9..e330cab 100644
--- a/content/docs/ja/next/client-libraries-java.html
+++ b/content/docs/ja/next/client-libraries-java.html
@@ -138,6 +138,13 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="default-broker-urls-for-standalone-clusters"></a><a href="#default-broker-urls-for-standalone-clusters" 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-1v1h [...]
<p>If you're running a cluster in <a href="/docs/ja/next/standalone">standalone mode</a>, the broker will be available at the <code>pulsar://localhost:6650</code> URL by default.</p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<p>| Type | Name | Description | Default |---|---|---|--- String | <code>serviceUrl</code> |Service URL provider for Pulsar service | None String | <code>authPluginClassName</code> | Name of the authentication plugin | None String | <code>authParams</code> | String represents parameters for the authentication plugin<br>
+<strong>Example</strong> <br>
+key1:val1,key2:val2|None long|<code>operationTimeoutMs</code>|Operation timeout |30000 long|<code>statsIntervalSeconds</code>|Interval between each stat info<br>
+Stats is activated with positive <code>statsInterval</code> <br>
+<code>statsIntervalSeconds</code> should be set to 1 second at least |60 int|<code>numIoThreads</code>| Number of threads used for handling connections to brokers | 1 int|<code>numListenerThreads</code>|Number of threads used for handling message listeners | 1 boolean|<code>useTcpNoDelay</code>|Whether to use TCP no-delay flag on the connection to disable Nagle algorithm |true boolean |<code>useTls</code> |Whether to use TLS encryption on the connection| false string | <code>tlsTrustCert [...]
+If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|<code>requestTimeoutMs</code>|Maximum duration for completing a request |60000 int|<code>defaultBackoffIntervalNanos</code>| Default duration for a backoff interval | TimeUnit.MILLISECONDS.toNanos(100); long|<code>maxBackoffIntervalNanos</code>|Maximum duration for a backoff interval|TimeUnit.SECONDS.toNanos(30)</p>
<p>Check out the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
class for a full listing of configurable parameters.</p>
<blockquote>
@@ -179,7 +186,8 @@ client.close();</p>
})<span class="hljs-comment">;</span>
</code></pre>
<h3><a class="anchor" aria-hidden="true" id="configuring-producers"></a><a href="#configuring-producers" 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 [...]
-<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set. For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set.</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
diff --git a/content/docs/ja/next/client-libraries-java/index.html b/content/docs/ja/next/client-libraries-java/index.html
index 33b75f9..e330cab 100644
--- a/content/docs/ja/next/client-libraries-java/index.html
+++ b/content/docs/ja/next/client-libraries-java/index.html
@@ -138,6 +138,13 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="default-broker-urls-for-standalone-clusters"></a><a href="#default-broker-urls-for-standalone-clusters" 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-1v1h [...]
<p>If you're running a cluster in <a href="/docs/ja/next/standalone">standalone mode</a>, the broker will be available at the <code>pulsar://localhost:6650</code> URL by default.</p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<p>| Type | Name | Description | Default |---|---|---|--- String | <code>serviceUrl</code> |Service URL provider for Pulsar service | None String | <code>authPluginClassName</code> | Name of the authentication plugin | None String | <code>authParams</code> | String represents parameters for the authentication plugin<br>
+<strong>Example</strong> <br>
+key1:val1,key2:val2|None long|<code>operationTimeoutMs</code>|Operation timeout |30000 long|<code>statsIntervalSeconds</code>|Interval between each stat info<br>
+Stats is activated with positive <code>statsInterval</code> <br>
+<code>statsIntervalSeconds</code> should be set to 1 second at least |60 int|<code>numIoThreads</code>| Number of threads used for handling connections to brokers | 1 int|<code>numListenerThreads</code>|Number of threads used for handling message listeners | 1 boolean|<code>useTcpNoDelay</code>|Whether to use TCP no-delay flag on the connection to disable Nagle algorithm |true boolean |<code>useTls</code> |Whether to use TLS encryption on the connection| false string | <code>tlsTrustCert [...]
+If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|<code>requestTimeoutMs</code>|Maximum duration for completing a request |60000 int|<code>defaultBackoffIntervalNanos</code>| Default duration for a backoff interval | TimeUnit.MILLISECONDS.toNanos(100); long|<code>maxBackoffIntervalNanos</code>|Maximum duration for a backoff interval|TimeUnit.SECONDS.toNanos(30)</p>
<p>Check out the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
class for a full listing of configurable parameters.</p>
<blockquote>
@@ -179,7 +186,8 @@ client.close();</p>
})<span class="hljs-comment">;</span>
</code></pre>
<h3><a class="anchor" aria-hidden="true" id="configuring-producers"></a><a href="#configuring-producers" 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 [...]
-<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set. For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+<p>If you instantiate a <code>Producer</code> object specifying only a topic name, as in the example above, the producer will use the default configuration. To use a non-default configuration, there's a variety of configurable parameters that you can set.</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
diff --git a/content/docs/zh-CN/concepts-tiered-storage.html b/content/docs/zh-CN/concepts-tiered-storage.html
index bbe74f0..0a8860c 100644
--- a/content/docs/zh-CN/concepts-tiered-storage.html
+++ b/content/docs/zh-CN/concepts-tiered-storage.html
@@ -80,7 +80,7 @@
<blockquote>
<p>写入bookKeeper的数据被默认复制到3台物理机。 但是，一旦segment在bookKeeper中被封闭，将会变成不可改变，并且可以被拷贝到长期存储中。 长期存储可以达到节省存储的目的，通过使用如 <a href="https://en.wikipedia.org/wiki/Reed%E2%80%93Solomon_error_correction">Reed-Solomon error correction</a> 的机制，只需更少的物理数据备份。</p>
</blockquote>
-<p>Pulsar currently supports S3 and Google Cloud Storage (GCS) for <a href="https://pulsar.apache.org/docs/en/cookbooks-tiered-storage/">long term store</a>. Offloading to long term storage triggered via a Rest API or command line interface. The user passes in the amount of topic data they wish to retain on bookkeeper, and the broker will copy the backlog data to long term storage. 原始数据将在配置的延迟时长后，从bookKeeper中删除（默认4小时）。</p>
+<p>Pulsar目前支持亚马逊的S3以及Google云存储GCS来作为长期存储。 可以通过Rest API或者命令行接口，将数据从短期数据卸载Offloading长期存储。 The user passes in the amount of topic data they wish to retain on bookkeeper, and the broker will copy the backlog data to long term storage. 原始数据将在配置的延迟时长后，从bookKeeper中删除（默认4小时）。</p></p>
<blockquote>
<p>搭建分层存储的指导，请参考 <a href="/docs/zh-CN/cookbooks-tiered-storage">Tiered storage cookbook</a>。</p>
</blockquote>
diff --git a/content/docs/zh-CN/concepts-tiered-storage/index.html b/content/docs/zh-CN/concepts-tiered-storage/index.html
index bbe74f0..0a8860c 100644
--- a/content/docs/zh-CN/concepts-tiered-storage/index.html
+++ b/content/docs/zh-CN/concepts-tiered-storage/index.html
@@ -80,7 +80,7 @@
<blockquote>
<p>写入bookKeeper的数据被默认复制到3台物理机。 但是，一旦segment在bookKeeper中被封闭，将会变成不可改变，并且可以被拷贝到长期存储中。 长期存储可以达到节省存储的目的，通过使用如 <a href="https://en.wikipedia.org/wiki/Reed%E2%80%93Solomon_error_correction">Reed-Solomon error correction</a> 的机制，只需更少的物理数据备份。</p>
</blockquote>
-<p>Pulsar currently supports S3 and Google Cloud Storage (GCS) for <a href="https://pulsar.apache.org/docs/en/cookbooks-tiered-storage/">long term store</a>. Offloading to long term storage triggered via a Rest API or command line interface. The user passes in the amount of topic data they wish to retain on bookkeeper, and the broker will copy the backlog data to long term storage. 原始数据将在配置的延迟时长后，从bookKeeper中删除（默认4小时）。</p>
+<p>Pulsar目前支持亚马逊的S3以及Google云存储GCS来作为长期存储。 可以通过Rest API或者命令行接口，将数据从短期数据卸载Offloading长期存储。 The user passes in the amount of topic data they wish to retain on bookkeeper, and the broker will copy the backlog data to long term storage. 原始数据将在配置的延迟时长后，从bookKeeper中删除（默认4小时）。</p></p>
<blockquote>
<p>搭建分层存储的指导，请参考 <a href="/docs/zh-CN/cookbooks-tiered-storage">Tiered storage cookbook</a>。</p>
</blockquote>
diff --git a/content/docs/zh-CN/next/client-libraries-java.html b/content/docs/zh-CN/next/client-libraries-java.html
index a974b3e..f8d1c44 100644
--- a/content/docs/zh-CN/next/client-libraries-java.html
+++ b/content/docs/zh-CN/next/client-libraries-java.html
@@ -138,6 +138,13 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="默认的broker-url是单机集群"></a><a href="#默认的broker-url是单机集群" 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- [...]
<p>如果你使用<a href="/docs/zh-CN/next/standalone">单机模式</a>运行一个集群，broker将默认使用<code>pulsar://localhost:6650</code></p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<p>| Type | Name | Description | Default |---|---|---|--- String | <code>serviceUrl</code> |Service URL provider for Pulsar service | None String | <code>authPluginClassName</code> | Name of the authentication plugin | None String | <code>authParams</code> | String represents parameters for the authentication plugin<br>
+<strong>Example</strong> <br>
+key1:val1,key2:val2|None long|<code>operationTimeoutMs</code>|Operation timeout |30000 long|<code>statsIntervalSeconds</code>|Interval between each stat info<br>
+Stats is activated with positive <code>statsInterval</code> <br>
+<code>statsIntervalSeconds</code> should be set to 1 second at least |60 int|<code>numIoThreads</code>| Number of threads used for handling connections to brokers | 1 int|<code>numListenerThreads</code>|Number of threads used for handling message listeners | 1 boolean|<code>useTcpNoDelay</code>|Whether to use TCP no-delay flag on the connection to disable Nagle algorithm |true boolean |<code>useTls</code> |Whether to use TLS encryption on the connection| false string | <code>tlsTrustCert [...]
+If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|<code>requestTimeoutMs</code>|Maximum duration for completing a request |60000 int|<code>defaultBackoffIntervalNanos</code>| Default duration for a backoff interval | TimeUnit.MILLISECONDS.toNanos(100); long|<code>maxBackoffIntervalNanos</code>|Maximum duration for a backoff interval|TimeUnit.SECONDS.toNanos(30)</p>
<p>完整的配置参数列表参考 <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
类的javadoc文档 。</p>
<blockquote>
@@ -179,8 +186,9 @@ client.close();</p>
})<span class="hljs-comment">;</span>
</code></pre>
<h3><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.09 [...]
-<p>如果实例化 <code>生产者</code> 对象时仅指定主题topic名称 (如上面的示例所示), 则生产者将使用默认配置。 要使用非默认配置, 你可以设置多种可配置的参数。 For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
- class. 下面是一个示例：</p>
+<p>如果实例化 <code>生产者</code> 对象时仅指定主题topic名称 (如上面的示例所示), 则生产者将使用默认配置。 要使用非默认配置, 你可以设置多种可配置的参数。</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+ class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
.batchingMaxPublishDelay(<span class="hljs-number">10</span>, TimeUnit.MILLISECONDS)
diff --git a/content/docs/zh-CN/next/client-libraries-java/index.html b/content/docs/zh-CN/next/client-libraries-java/index.html
index a974b3e..f8d1c44 100644
--- a/content/docs/zh-CN/next/client-libraries-java/index.html
+++ b/content/docs/zh-CN/next/client-libraries-java/index.html
@@ -138,6 +138,13 @@ dependencies {
<h4><a class="anchor" aria-hidden="true" id="默认的broker-url是单机集群"></a><a href="#默认的broker-url是单机集群" 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- [...]
<p>如果你使用<a href="/docs/zh-CN/next/standalone">单机模式</a>运行一个集群，broker将默认使用<code>pulsar://localhost:6650</code></p>
</blockquote>
+<p>If you create a client, you may use the <code>loadConf</code> configuration. Below are the available parameters used in <code>loadConf</code>.</p>
+<p>| Type | Name | Description | Default |---|---|---|--- String | <code>serviceUrl</code> |Service URL provider for Pulsar service | None String | <code>authPluginClassName</code> | Name of the authentication plugin | None String | <code>authParams</code> | String represents parameters for the authentication plugin<br>
+<strong>Example</strong> <br>
+key1:val1,key2:val2|None long|<code>operationTimeoutMs</code>|Operation timeout |30000 long|<code>statsIntervalSeconds</code>|Interval between each stat info<br>
+Stats is activated with positive <code>statsInterval</code> <br>
+<code>statsIntervalSeconds</code> should be set to 1 second at least |60 int|<code>numIoThreads</code>| Number of threads used for handling connections to brokers | 1 int|<code>numListenerThreads</code>|Number of threads used for handling message listeners | 1 boolean|<code>useTcpNoDelay</code>|Whether to use TCP no-delay flag on the connection to disable Nagle algorithm |true boolean |<code>useTls</code> |Whether to use TLS encryption on the connection| false string | <code>tlsTrustCert [...]
+If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|<code>requestTimeoutMs</code>|Maximum duration for completing a request |60000 int|<code>defaultBackoffIntervalNanos</code>| Default duration for a backoff interval | TimeUnit.MILLISECONDS.toNanos(100); long|<code>maxBackoffIntervalNanos</code>|Maximum duration for a backoff interval|TimeUnit.SECONDS.toNanos(30)</p>
<p>完整的配置参数列表参考 <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/PulsarClient">PulsarClient</a>
类的javadoc文档 。</p>
<blockquote>
@@ -179,8 +186,9 @@ client.close();</p>
})<span class="hljs-comment">;</span>
</code></pre>
<h3><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.09 [...]
-<p>如果实例化 <code>生产者</code> 对象时仅指定主题topic名称 (如上面的示例所示), 则生产者将使用默认配置。 要使用非默认配置, 你可以设置多种可配置的参数。 For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
- class. 下面是一个示例：</p>
+<p>如果实例化 <code>生产者</code> 对象时仅指定主题topic名称 (如上面的示例所示), 则生产者将使用默认配置。 要使用非默认配置, 你可以设置多种可配置的参数。</p>
+<p>For a full listing, see the Javadoc for the <a href="https://pulsar.incubator.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder">ProducerBuilder</a>
+ class. Here's an example:</p>
<pre><code class="hljs css language-java">Producer<<span class="hljs-keyword">byte</span>[]> producer = client.newProducer()
.topic(<span class="hljs-string">"my-topic"</span>)
.batchingMaxPublishDelay(<span class="hljs-number">10</span>, TimeUnit.MILLISECONDS)
diff --git a/content/docs/zh-CN/next/concepts-tiered-storage.html b/content/docs/zh-CN/next/concepts-tiered-storage.html
index 2cc439b..9fd59fa 100644
--- a/content/docs/zh-CN/next/concepts-tiered-storage.html
+++ b/content/docs/zh-CN/next/concepts-tiered-storage.html
@@ -75,12 +75,12 @@
}
});
</script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Tiered Storage</h1></header><article><div><span><p>Pulsar面向segment的架构允许topic backlog增长的十分庞大，如果有没加以限制，随着时间的增加，代价将越来越高。</p>
-<p>有一个减轻这个消耗的办法，那就是使用分层存储。 With tiered storage, older messages in the backlog can be moved from BookKeeper to a cheaper storage mechanism, while still allowing clients to access the backlog as if nothing had changed.</p>
+<p>有一个减轻这个消耗的办法，那就是使用分层存储。 通过分层存储，在backlog中的旧消息可以从BookKeeper转移到更连接的存储器中，如果不发生变化客户端仍然可以通过backlog去访问。</p>
<p><img src="/docs/assets/pulsar-tiered-storage.png" alt="Tiered Storage"></p>
<blockquote>
-<p>Data written to BookKeeper is replicated to 3 physical machines by default. However, once a segment is sealed in BookKeeper it becomes immutable and can be copied to long term storage. 长期存储可以达到节省存储的目的，通过使用如 <a href="https://en.wikipedia.org/wiki/Reed%E2%80%93Solomon_error_correction">Reed-Solomon error correction</a> 的机制，只需更少的物理数据备份。</p>
+<p>默认情况下写入到BookKeeper的数据有三个物理机器作为副本。 但是，一旦一个段被BookKeep封上后，该段就变得不可改变，此时可以复制到长期存储中去了。 长期存储可以达到节省存储的目的，通过使用如 <a href="https://en.wikipedia.org/wiki/Reed%E2%80%93Solomon_error_correction">Reed-Solomon error correction</a> 的机制，只需更少的物理数据备份。</p>
</blockquote>
-<p>Pulsar currently supports S3 and Google Cloud Storage (GCS) for <a href="https://pulsar.apache.org/docs/en/cookbooks-tiered-storage/">long term store</a>. Offloading to long term storage triggered via a Rest API or command line interface. The user passes in the amount of topic data they wish to retain on BookKeeper, and the broker will copy the backlog data to long term storage. The original data will then be deleted from BookKeeper after a configured delay (4 hours by default).</p>
+<p>Pulsar目前支持亚马逊的S3以及Google云存储GCS来作为长期存储。 可以通过Rest API或者命令行接口，将数据从短期数据卸载Offloading长期存储。 用户传入他们想要保留在BookKeeper上的大量Topic数据，Broker会复制backlog数据到长期存储。 通过一个可配置的延时（默认是4小时），与那时数据会从BookKeeper上被删除。</p></p>
<blockquote>
<p>搭建分层存储的指导，请参考 <a href="/docs/zh-CN/next/cookbooks-tiered-storage">Tiered storage cookbook</a>。</p>
</blockquote>
diff --git a/content/docs/zh-CN/next/concepts-tiered-storage/index.html b/content/docs/zh-CN/next/concepts-tiered-storage/index.html
index 2cc439b..9fd59fa 100644
--- a/content/docs/zh-CN/next/concepts-tiered-storage/index.html
+++ b/content/docs/zh-CN/next/concepts-tiered-storage/index.html
@@ -75,12 +75,12 @@
}
});
</script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Tiered Storage</h1></header><article><div><span><p>Pulsar面向segment的架构允许topic backlog增长的十分庞大，如果有没加以限制，随着时间的增加，代价将越来越高。</p>
-<p>有一个减轻这个消耗的办法，那就是使用分层存储。 With tiered storage, older messages in the backlog can be moved from BookKeeper to a cheaper storage mechanism, while still allowing clients to access the backlog as if nothing had changed.</p>
+<p>有一个减轻这个消耗的办法，那就是使用分层存储。 通过分层存储，在backlog中的旧消息可以从BookKeeper转移到更连接的存储器中，如果不发生变化客户端仍然可以通过backlog去访问。</p>
<p><img src="/docs/assets/pulsar-tiered-storage.png" alt="Tiered Storage"></p>
<blockquote>
-<p>Data written to BookKeeper is replicated to 3 physical machines by default. However, once a segment is sealed in BookKeeper it becomes immutable and can be copied to long term storage. 长期存储可以达到节省存储的目的，通过使用如 <a href="https://en.wikipedia.org/wiki/Reed%E2%80%93Solomon_error_correction">Reed-Solomon error correction</a> 的机制，只需更少的物理数据备份。</p>
+<p>默认情况下写入到BookKeeper的数据有三个物理机器作为副本。 但是，一旦一个段被BookKeep封上后，该段就变得不可改变，此时可以复制到长期存储中去了。 长期存储可以达到节省存储的目的，通过使用如 <a href="https://en.wikipedia.org/wiki/Reed%E2%80%93Solomon_error_correction">Reed-Solomon error correction</a> 的机制，只需更少的物理数据备份。</p>
</blockquote>
-<p>Pulsar currently supports S3 and Google Cloud Storage (GCS) for <a href="https://pulsar.apache.org/docs/en/cookbooks-tiered-storage/">long term store</a>. Offloading to long term storage triggered via a Rest API or command line interface. The user passes in the amount of topic data they wish to retain on BookKeeper, and the broker will copy the backlog data to long term storage. The original data will then be deleted from BookKeeper after a configured delay (4 hours by default).</p>
+<p>Pulsar目前支持亚马逊的S3以及Google云存储GCS来作为长期存储。 可以通过Rest API或者命令行接口，将数据从短期数据卸载Offloading长期存储。 用户传入他们想要保留在BookKeeper上的大量Topic数据，Broker会复制backlog数据到长期存储。 通过一个可配置的延时（默认是4小时），与那时数据会从BookKeeper上被删除。</p></p>
<blockquote>
<p>搭建分层存储的指导，请参考 <a href="/docs/zh-CN/next/cookbooks-tiered-storage">Tiered storage cookbook</a>。</p>
</blockquote>
diff --git a/content/swagger/2.5.0-SNAPSHOT/swagger.json b/content/swagger/2.5.0-SNAPSHOT/swagger.json
index 17ff2d2..31608dc 100644
--- a/content/swagger/2.5.0-SNAPSHOT/swagger.json
+++ b/content/swagger/2.5.0-SNAPSHOT/swagger.json
@@ -4784,7 +4784,7 @@
"200" : {
"description" : "successful operation",
"schema" : {
- "$ref" : "#/definitions/NonPersistentTopicStats"
+ "$ref" : "#/definitions/TopicStats"
}
},
"401" : {
@@ -8866,41 +8866,41 @@
"type" : "number",
"format" : "double"
},
- "bandwidthIn" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "bandwidthOut" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "memory" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "cpu" : {
- "$ref" : "#/definitions/ResourceUsage"
+ "underLoaded" : {
+ "type" : "boolean"
},
- "directMemory" : {
- "$ref" : "#/definitions/ResourceUsage"
+ "msgThroughputIn" : {
+ "type" : "number",
+ "format" : "double"
},
"lastUpdate" : {
"type" : "integer",
"format" : "int64"
},
- "msgThroughputIn" : {
- "type" : "number",
- "format" : "double"
+ "cpu" : {
+ "$ref" : "#/definitions/ResourceUsage"
},
"msgThroughputOut" : {
"type" : "number",
"format" : "double"
},
- "underLoaded" : {
- "type" : "boolean"
- },
"overLoaded" : {
"type" : "boolean"
},
"loadReportType" : {
"type" : "string"
+ },
+ "directMemory" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "bandwidthIn" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "bandwidthOut" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "memory" : {
+ "$ref" : "#/definitions/ResourceUsage"
}
}
},
@@ -9847,11 +9847,11 @@
"ResourceUnit" : {
"type" : "object",
"properties" : {
- "resourceId" : {
- "type" : "string"
- },
"availableResource" : {
"$ref" : "#/definitions/ResourceDescription"
+ },
+ "resourceId" : {
+ "type" : "string"
}
}
},
diff --git a/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json b/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
index 6a03c87..2ed9644 100644
--- a/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
+++ b/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
@@ -1348,17 +1348,6 @@
"Message" : {
"type" : "object",
"properties" : {
- "replicated" : {
- "type" : "boolean"
- },
- "publishTime" : {
- "type" : "integer",
- "format" : "int64"
- },
- "eventTime" : {
- "type" : "integer",
- "format" : "int64"
- },
"messageId" : {
"$ref" : "#/definitions/MessageId"
},
@@ -1366,6 +1355,16 @@
"type" : "integer",
"format" : "int64"
},
+ "replicatedFrom" : {
+ "type" : "string"
+ },
+ "orderingKey" : {
+ "type" : "array",
+ "items" : {
+ "type" : "string",
+ "format" : "byte"
+ }
+ },
"encryptionCtx" : {
"$ref" : "#/definitions/EncryptionContext"
},
@@ -1380,16 +1379,23 @@
"format" : "byte"
}
},
- "orderingKey" : {
- "type" : "array",
- "items" : {
- "type" : "string",
- "format" : "byte"
- }
+ "replicated" : {
+ "type" : "boolean"
+ },
+ "publishTime" : {
+ "type" : "integer",
+ "format" : "int64"
+ },
+ "eventTime" : {
+ "type" : "integer",
+ "format" : "int64"
},
"topicName" : {
"type" : "string"
},
+ "producerName" : {
+ "type" : "string"
+ },
"keyBytes" : {
"type" : "array",
"items" : {
@@ -1397,12 +1403,6 @@
"format" : "byte"
}
},
- "replicatedFrom" : {
- "type" : "string"
- },
- "producerName" : {
- "type" : "string"
- },
"data" : {
"type" : "array",
"items" : {
diff --git a/content/swagger/swagger.json b/content/swagger/swagger.json
index 17ff2d2..31608dc 100644
--- a/content/swagger/swagger.json
+++ b/content/swagger/swagger.json
@@ -4784,7 +4784,7 @@
"200" : {
"description" : "successful operation",
"schema" : {
- "$ref" : "#/definitions/NonPersistentTopicStats"
+ "$ref" : "#/definitions/TopicStats"
}
},
"401" : {
@@ -8866,41 +8866,41 @@
"type" : "number",
"format" : "double"
},
- "bandwidthIn" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "bandwidthOut" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "memory" : {
- "$ref" : "#/definitions/ResourceUsage"
- },
- "cpu" : {
- "$ref" : "#/definitions/ResourceUsage"
+ "underLoaded" : {
+ "type" : "boolean"
},
- "directMemory" : {
- "$ref" : "#/definitions/ResourceUsage"
+ "msgThroughputIn" : {
+ "type" : "number",
+ "format" : "double"
},
"lastUpdate" : {
"type" : "integer",
"format" : "int64"
},
- "msgThroughputIn" : {
- "type" : "number",
- "format" : "double"
+ "cpu" : {
+ "$ref" : "#/definitions/ResourceUsage"
},
"msgThroughputOut" : {
"type" : "number",
"format" : "double"
},
- "underLoaded" : {
- "type" : "boolean"
- },
"overLoaded" : {
"type" : "boolean"
},
"loadReportType" : {
"type" : "string"
+ },
+ "directMemory" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "bandwidthIn" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "bandwidthOut" : {
+ "$ref" : "#/definitions/ResourceUsage"
+ },
+ "memory" : {
+ "$ref" : "#/definitions/ResourceUsage"
}
}
},
@@ -9847,11 +9847,11 @@
"ResourceUnit" : {
"type" : "object",
"properties" : {
- "resourceId" : {
- "type" : "string"
- },
"availableResource" : {
"$ref" : "#/definitions/ResourceDescription"
+ },
+ "resourceId" : {
+ "type" : "string"
}
}
},
diff --git a/content/swagger/swaggerfunctions.json b/content/swagger/swaggerfunctions.json
index 6a03c87..2ed9644 100644
--- a/content/swagger/swaggerfunctions.json
+++ b/content/swagger/swaggerfunctions.json
@@ -1348,17 +1348,6 @@
"Message" : {
"type" : "object",
"properties" : {
- "replicated" : {
- "type" : "boolean"
- },
- "publishTime" : {
- "type" : "integer",
- "format" : "int64"
- },
- "eventTime" : {
- "type" : "integer",
- "format" : "int64"
- },
"messageId" : {
"$ref" : "#/definitions/MessageId"
},
@@ -1366,6 +1355,16 @@
"type" : "integer",
"format" : "int64"
},
+ "replicatedFrom" : {
+ "type" : "string"
+ },
+ "orderingKey" : {
+ "type" : "array",
+ "items" : {
+ "type" : "string",
+ "format" : "byte"
+ }
+ },
"encryptionCtx" : {
"$ref" : "#/definitions/EncryptionContext"
},
@@ -1380,16 +1379,23 @@
"format" : "byte"
}
},
- "orderingKey" : {
- "type" : "array",
- "items" : {
- "type" : "string",
- "format" : "byte"
- }
+ "replicated" : {
+ "type" : "boolean"
+ },
+ "publishTime" : {
+ "type" : "integer",
+ "format" : "int64"
+ },
+ "eventTime" : {
+ "type" : "integer",
+ "format" : "int64"
},
"topicName" : {
"type" : "string"
},
+ "producerName" : {
+ "type" : "string"
+ },
"keyBytes" : {
"type" : "array",
"items" : {
@@ -1397,12 +1403,6 @@
"format" : "byte"
}
},
- "replicatedFrom" : {
- "type" : "string"
- },
- "producerName" : {
- "type" : "string"
- },
"data" : {
"type" : "array",
"items" : {