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/incubator-pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 951af0f Updated site at revision 16a554b
951af0f is described below
commit 951af0f470ee8ed448aa9e723e5ec0c043e84f96
Author: jenkins <bui...@apache.org>
AuthorDate: Sat Feb 10 08:14:01 2018 +0000
Updated site at revision 16a554b
---
content/api/client/index-all.html | 6 ++
.../pulsar/client/api/ClientConfiguration.html | 71 ++++++++++---
content/api/client/serialized-form.html | 4 +
.../docs/latest/adaptors/KafkaWrapper/index.html | 116 ++++++++++++++++++++-
4 files changed, 176 insertions(+), 21 deletions(-)
diff --git a/content/api/client/index-all.html
b/content/api/client/index-all.html
index 6271bb5..30ce595 100644
--- a/content/api/client/index-all.html
+++ b/content/api/client/index-all.html
@@ -581,6 +581,8 @@
</dd>
<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ClientConfiguration.html#isTlsAllowInsecureConnection--">isTlsAllowInsecureConnection()</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ClientConfiguration.html" title="class in
org.apache.pulsar.client.api">ClientConfiguration</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ClientConfiguration.html#isTlsHostnameVerificationEnable--">isTlsHostnameVerificationEnable()</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ClientConfiguration.html" title="class in
org.apache.pulsar.client.api">ClientConfiguration</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ClientConfiguration.html#isUseTcpNoDelay--">isUseTcpNoDelay()</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ClientConfiguration.html" title="class in
org.apache.pulsar.client.api">ClientConfiguration</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ClientConfiguration.html#isUseTls--">isUseTls()</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ClientConfiguration.html" title="class in
org.apache.pulsar.client.api">ClientConfiguration</a></dt>
@@ -1053,6 +1055,10 @@
<dd>
<div class="block">Configure whether the Pulsar client accept untrusted TLS
certificate from broker <i>(default: false)</i></div>
</dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ClientConfiguration.html#setTlsHostnameVerificationEnable-boolean-">setTlsHostnameVerificationEnable(boolean)</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ClientConfiguration.html" title="class in
org.apache.pulsar.client.api">ClientConfiguration</a></dt>
+<dd>
+<div class="block">It allows to validate hostname verification when client
connects to broker over tls.</div>
+</dd>
<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ClientConfiguration.html#setTlsTrustCertsFilePath-java.lang.String-">setTlsTrustCertsFilePath(String)</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ClientConfiguration.html" title="class in
org.apache.pulsar.client.api">ClientConfiguration</a></dt>
<dd>
<div class="block">Set the path to the trusted TLS certificate file</div>
diff --git
a/content/api/client/org/apache/pulsar/client/api/ClientConfiguration.html
b/content/api/client/org/apache/pulsar/client/api/ClientConfiguration.html
index 5b35115..0e4b961 100644
--- a/content/api/client/org/apache/pulsar/client/api/ClientConfiguration.html
+++ b/content/api/client/org/apache/pulsar/client/api/ClientConfiguration.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -202,57 +202,61 @@ implements Serializable</pre>
</tr>
<tr id="i10" class="altColor">
<td class="colFirst"><code>boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#isUseTcpNoDelay--">isUseTcpNoDelay</a></span>()</code> </td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#isTlsHostnameVerificationEnable--">isTlsHostnameVerificationEnable</a></span>()</code> </td>
</tr>
<tr id="i11" class="rowColor">
<td class="colFirst"><code>boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#isUseTls--">isUseTls</a></span>()</code> </td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#isUseTcpNoDelay--">isUseTcpNoDelay</a></span>()</code> </td>
</tr>
<tr id="i12" class="altColor">
+<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#isUseTls--">isUseTls</a></span>()</code> </td>
+</tr>
+<tr id="i13" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setAuthentication-org.apache.pulsar.client.api.Authentication-">setAuthentication</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/Authentication.html"
title="interface in
org.apache.pulsar.client.api">Authentication</a> authentication)</code>
<div class="block">Set the authentication provider to use in the Pulsar client
instance.</div>
</td>
</tr>
-<tr id="i13" class="rowColor">
+<tr id="i14" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setAuthentication-java.lang.String-java.util.Map-">setAuthentication</a></span>(String authPluginClassName,
Map<String,String> authParams)</code>
<div class="block">Set the authentication provider to use in the Pulsar client
instance.</div>
</td>
</tr>
-<tr id="i14" class="altColor">
+<tr id="i15" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setAuthentication-java.lang.String-java.lang.String-">setAuthentication</a></span>(String authPluginClassName,
String authParamsString)</code>
<div class="block">Set the authentication provider to use in the Pulsar client
instance.</div>
</td>
</tr>
-<tr id="i15" class="rowColor">
+<tr id="i16" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setConcurrentLookupRequest-int-">setConcurrentLookupRequest</a></span>(int concurrentLookupRequest)</code>
<div class="block">Number of concurrent lookup-requests allowed on each
broker-connection to prevent overload on broker.</div>
</td>
</tr>
-<tr id="i16" class="altColor">
+<tr id="i17" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setConnectionsPerBroker-int-">setConnectionsPerBroker</a></span>(int connectionsPerBroker)</code>
<div class="block">Sets the max number of connection that the client library
will open to a single broker.</div>
</td>
</tr>
-<tr id="i17" class="rowColor">
+<tr id="i18" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setIoThreads-int-">setIoThreads</a></span>(int numIoThreads)</code>
<div class="block">Set the number of threads to be used for handling
connections to brokers <i>(default: 1 thread)</i></div>
</td>
</tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setListenerThreads-int-">setListenerThreads</a></span>(int numListenerThreads)</code>
<div class="block">Set the number of threads to be used for message listeners
<i>(default: 1 thread)</i></div>
</td>
</tr>
-<tr id="i19" class="rowColor">
+<tr id="i20" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setMaxNumberOfRejectedRequestPerConnection-int-">setMaxNumberOfRejectedRequestPerConnection</a></span>(int maxNumberOfRejectedRequestPerConnection)</code>
<div class="block">Set max number of broker-rejected requests in a certain
time-frame (30 seconds) after which current connection
@@ -260,14 +264,14 @@ implements Serializable</pre>
50)</i></div>
</td>
</tr>
-<tr id="i20" class="altColor">
+<tr id="i21" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setOperationTimeout-int-java.util.concurrent.TimeUnit-">setOperationTimeout</a></span>(int operationTimeout,
TimeUnit unit)</code>
<div class="block">Set the operation timeout <i>(default: 30 seconds)</i></div>
</td>
</tr>
-<tr id="i21" class="rowColor">
+<tr id="i22" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setStatsInterval-long-java.util.concurrent.TimeUnit-">setStatsInterval</a></span>(long statsInterval,
TimeUnit unit)</code>
@@ -275,25 +279,31 @@ implements Serializable</pre>
statsIntervalSeconds It should be set to at least 1 second</div>
</td>
</tr>
-<tr id="i22" class="altColor">
+<tr id="i23" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setTlsAllowInsecureConnection-boolean-">setTlsAllowInsecureConnection</a></span>(boolean tlsAllowInsecureConnection)</code>
<div class="block">Configure whether the Pulsar client accept untrusted TLS
certificate from broker <i>(default: false)</i></div>
</td>
</tr>
-<tr id="i23" class="rowColor">
+<tr id="i24" class="altColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setTlsHostnameVerificationEnable-boolean-">setTlsHostnameVerificationEnable</a></span>(boolean tlsHostnameVerificationEnable)</code>
+<div class="block">It allows to validate hostname verification when client
connects to broker over tls.</div>
+</td>
+</tr>
+<tr id="i25" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setTlsTrustCertsFilePath-java.lang.String-">setTlsTrustCertsFilePath</a></span>(String tlsTrustCertsFilePath)</code>
<div class="block">Set the path to the trusted TLS certificate file</div>
</td>
</tr>
-<tr id="i24" class="altColor">
+<tr id="i26" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setUseTcpNoDelay-boolean-">setUseTcpNoDelay</a></span>(boolean useTcpNoDelay)</code>
<div class="block">Configure whether to use TCP no-delay flag on the
connection, to disable Nagle algorithm.</div>
</td>
</tr>
-<tr id="i25" class="rowColor">
+<tr id="i27" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setUseTls-boolean-">setUseTls</a></span>(boolean useTls)</code>
<div class="block">Configure whether to use TLS encryption on the connection
<i>(default: false)</i></div>
@@ -754,7 +764,7 @@ implements Serializable</pre>
<a name="setMaxNumberOfRejectedRequestPerConnection-int-">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>setMaxNumberOfRejectedRequestPerConnection</h4>
<pre>public void setMaxNumberOfRejectedRequestPerConnection(int maxNumberOfRejectedRequestPerConnection)</pre>
@@ -767,6 +777,33 @@ implements Serializable</pre>
</dl>
</li>
</ul>
+<a name="isTlsHostnameVerificationEnable--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>isTlsHostnameVerificationEnable</h4>
+<pre>public boolean isTlsHostnameVerificationEnable()</pre>
+</li>
+</ul>
+<a name="setTlsHostnameVerificationEnable-boolean-">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>setTlsHostnameVerificationEnable</h4>
+<pre>public void setTlsHostnameVerificationEnable(boolean tlsHostnameVerificationEnable)</pre>
+<div class="block">It allows to validate hostname verification when client
connects to broker over tls. It validates incoming x509
+ certificate and matches provided hostname(CN/SAN) with expected broker's host
name. It follows RFC 2818, 3.1. Server
+ Identity hostname verification.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>tlsHostnameVerificationEnable</code> - </dd>
+<dt><span class="seeLabel">See Also:</span></dt>
+<dd><a href="https://tools.ietf.org/html/rfc2818";>rfc2818</a></dd>
+</dl>
+</li>
+</ul>
</li>
</ul>
</li>
diff --git a/content/api/client/serialized-form.html
b/content/api/client/serialized-form.html
index 19fe3dd..5cfebc3 100644
--- a/content/api/client/serialized-form.html
+++ b/content/api/client/serialized-form.html
@@ -128,6 +128,10 @@
<pre>boolean tlsAllowInsecureConnection</pre>
</li>
<li class="blockList">
+<h4>tlsHostnameVerificationEnable</h4>
+<pre>boolean tlsHostnameVerificationEnable</pre>
+</li>
+<li class="blockList">
<h4>concurrentLookupRequest</h4>
<pre>int concurrentLookupRequest</pre>
</li>
diff --git a/content/docs/latest/adaptors/KafkaWrapper/index.html
b/content/docs/latest/adaptors/KafkaWrapper/index.html
index bccf582..dc2524e 100644
--- a/content/docs/latest/adaptors/KafkaWrapper/index.html
+++ b/content/docs/latest/adaptors/KafkaWrapper/index.html
@@ -1905,7 +1905,7 @@ Pulsar topic.</p>
<p>You can configure Pulsar authentication provider directly from the Kafka
properties.</p>
-<p>Properties:</p>
+<h3 id="pulsar-client-properties">Pulsar client properties:</h3>
<table>
<thead>
@@ -1922,20 +1922,128 @@ Pulsar topic.</p>
<td style="text-align: left">Configure to auth provider. Eg. <code
class="highlighter-rouge">org.apache.pulsar.client.impl.auth.AuthenticationTls</code></td>
</tr>
<tr>
- <td style="text-align: left"><code
class="highlighter-rouge">pulsar.use.tls</code></td>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setUseTls-boolean-";><code
class="highlighter-rouge">pulsar.use.tls</code></a></td>
<td style="text-align: left"><code
class="highlighter-rouge">false</code></td>
<td style="text-align: left">Enable TLS transport encryption</td>
</tr>
<tr>
- <td style="text-align: left"><code
class="highlighter-rouge">pulsar.tls.trust.certs.file.path</code></td>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setTlsTrustCertsFilePath-java.lang.String-";><code
class="highlighter-rouge">pulsar.tls.trust.certs.file.path</code></a></td>
<td style="text-align: left"> </td>
<td style="text-align: left">Path for the TLS trust certificate
store</td>
</tr>
<tr>
- <td style="text-align: left"><code
class="highlighter-rouge">pulsar.tls.allow.insecure.connection</code></td>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setTlsAllowInsecureConnection-boolean-";><code
class="highlighter-rouge">pulsar.tls.allow.insecure.connection</code></a></td>
<td style="text-align: left"><code
class="highlighter-rouge">false</code></td>
<td style="text-align: left">Accept self-signed certificates from
brokers</td>
</tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setOperationTimeout-int-java.util.concurrent.TimeUnit-";><code
class="highlighter-rouge">pulsar.operation.timeout.ms</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">30000</code></td>
+ <td style="text-align: left">General operations timeout</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setStatsInterval-long-java.util.concurrent.TimeUnit-";><code
class="highlighter-rouge">pulsar.stats.interval.seconds</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">60</code></td>
+ <td style="text-align: left">Pulsar client lib stats printing
interval</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setIoThreads-int-";><code
class="highlighter-rouge">pulsar.num.io.threads</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">1</code></td>
+ <td style="text-align: left">Number of Netty IO threads to use</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setConnectionsPerBroker-int-";><code
class="highlighter-rouge">pulsar.connections.per.broker</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">1</code></td>
+ <td style="text-align: left">Max number of connection to open to each
broker</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setUseTcpNoDelay-boolean-";><code
class="highlighter-rouge">pulsar.use.tcp.nodelay</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">true</code></td>
+ <td style="text-align: left">TCP no-delay</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setConcurrentLookupRequest-int-";><code
class="highlighter-rouge">pulsar.concurrent.lookup.requests</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">50000</code></td>
+ <td style="text-align: left">Max number of concurrent topic lookups</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ClientConfiguration.html#setMaxNumberOfRejectedRequestPerConnection-int-";><code
class="highlighter-rouge">pulsar.max.number.rejected.request.per.connection</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">50</code></td>
+ <td style="text-align: left">Threshold of errors to forcefully close a
connection</td>
+ </tr>
+ </tbody>
+</table>
+
+<h3 id="pulsar-producer-properties">Pulsar producer properties</h3>
+
+<table>
+ <thead>
+ <tr>
+ <th style="text-align: left">Config property</th>
+ <th style="text-align: left">Default</th>
+ <th style="text-align: left">Notes</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setProducerName-java.lang.String-";><code
class="highlighter-rouge">pulsar.producer.name</code></a></td>
+ <td style="text-align: left"> </td>
+ <td style="text-align: left">Specify producer name</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setInitialSequenceId-long-";><code
class="highlighter-rouge">pulsar.producer.initial.sequence.id</code></a></td>
+ <td style="text-align: left"> </td>
+ <td style="text-align: left">Specify baseline for sequence id for this
producer</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setMaxPendingMessages-int-";><code
class="highlighter-rouge">pulsar.producer.max.pending.messages</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">1000</code></td>
+ <td style="text-align: left">Set the max size of the queue holding the
messages pending to receive an acknowledgment from the broker.</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setMaxPendingMessagesAcrossPartitions-int-";><code
class="highlighter-rouge">pulsar.producer.max.pending.messages.across.partitions</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">50000</code></td>
+ <td style="text-align: left">Set the number of max pending messages
across all the partitions</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setBatchingEnabled-boolean-";><code
class="highlighter-rouge">pulsar.producer.batching.enabled</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">true</code></td>
+ <td style="text-align: left">Control whether automatic batching of
messages is enabled for the producer</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setBatchingMaxMessages-int-";><code
class="highlighter-rouge">pulsar.producer.batching.max.messages</code></a></td>
+ <td style="text-align: left"><code
class="highlighter-rouge">1000</code></td>
+ <td style="text-align: left">The maximum number of messages permitted in
a batch</td>
+ </tr>
+ </tbody>
+</table>
+
+<h3 id="pulsar-consumer-properties">Pulsar consumer Properties</h3>
+
+<table>
+ <thead>
+ <tr>
+ <th style="text-align: left">Config property</th>
+ <th style="text-align: left">Default</th>
+ <th style="text-align: left">Notes</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setConsumerName-java.lang.String-";><code
class="highlighter-rouge">pulsar.consumer.name</code></a></td>
+ <td style="text-align: left"> </td>
+ <td style="text-align: left">Set the consumer name</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setReceiverQueueSize-int-";><code
class="highlighter-rouge">pulsar.consumer.receiver.queue.size</code></a></td>
+ <td style="text-align: left">1000</td>
+ <td style="text-align: left">Sets the size of the consumer receive
queue</td>
+ </tr>
+ <tr>
+ <td style="text-align: left"><a
href="http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setMaxTotalReceiverQueueSizeAcrossPartitions-int-";><code
class="highlighter-rouge">pulsar.consumer.total.receiver.queue.size.across.partitions</code></a></td>
+ <td style="text-align: left">50000</td>
+ <td style="text-align: left">Set the max total receiver queue size
across partitons</td>
+ </tr>
</tbody>
</table>
--
To stop receiving notification emails like this one, please contact
mme...@apache.org.
