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 2018/02/25 08:14:19 UTC
[incubator-pulsar] branch asf-site updated: Updated site at
revision 1a1a6e3
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 576549a Updated site at revision 1a1a6e3
576549a is described below
commit 576549a4639d76d844df5f2fbf9a86ad0ef08d67
Author: jenkins <bu...@apache.org>
AuthorDate: Sun Feb 25 08:14:12 2018 +0000
Updated site at revision 1a1a6e3
---
content/api/client/allclasses-frame.html | 1 +
content/api/client/allclasses-noframe.html | 1 +
content/api/client/index-all.html | 51 ++++-
.../pulsar/client/api/ClientConfiguration.html | 112 ++++++----
.../pulsar/client/api/ConsumerConfiguration.html | 90 ++++----
.../pulsar/client/api/EncryptionKeyInfo.html | 4 +-
...{MessageRoutingMode.html => HashingScheme.html} | 82 ++++----
.../org/apache/pulsar/client/api/Message.html | 4 +-
.../pulsar/client/api/MessageRoutingMode.html | 19 +-
.../apache/pulsar/client/api/ProducerBuilder.html | 69 ++++--
.../pulsar/client/api/ProducerConfiguration.html | 60 +++---
.../pulsar/client/api/ReaderConfiguration.html | 34 ++-
.../apache/pulsar/client/api/package-frame.html | 1 +
.../apache/pulsar/client/api/package-summary.html | 18 +-
.../org/apache/pulsar/client/api/package-tree.html | 1 +
content/api/client/overview-tree.html | 1 +
content/api/client/serialized-form.html | 231 +--------------------
17 files changed, 358 insertions(+), 421 deletions(-)
diff --git a/content/api/client/allclasses-frame.html b/content/api/client/allclasses-frame.html
index 7a429d7..23b0dd7 100644
--- a/content/api/client/allclasses-frame.html
+++ b/content/api/client/allclasses-frame.html
@@ -27,6 +27,7 @@
<li><a href="org/apache/pulsar/client/api/url/DataURLStreamHandler.html" title="class in org.apache.pulsar.client.api.url" target="classFrame">DataURLStreamHandler</a></li>
<li><a href="org/apache/pulsar/client/api/EncodedAuthenticationParameterSupport.html" title="interface in org.apache.pulsar.client.api" target="classFrame"><span class="interfaceName">EncodedAuthenticationParameterSupport</span></a></li>
<li><a href="org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api" target="classFrame">EncryptionKeyInfo</a></li>
+<li><a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api" target="classFrame">HashingScheme</a></li>
<li><a href="org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api" target="classFrame"><span class="interfaceName">Message</span></a></li>
<li><a href="org/apache/pulsar/client/api/MessageBuilder.html" title="interface in org.apache.pulsar.client.api" target="classFrame"><span class="interfaceName">MessageBuilder</span></a></li>
<li><a href="org/apache/pulsar/client/api/MessageId.html" title="interface in org.apache.pulsar.client.api" target="classFrame"><span class="interfaceName">MessageId</span></a></li>
diff --git a/content/api/client/allclasses-noframe.html b/content/api/client/allclasses-noframe.html
index 62f4f26..1acfda3 100644
--- a/content/api/client/allclasses-noframe.html
+++ b/content/api/client/allclasses-noframe.html
@@ -27,6 +27,7 @@
<li><a href="org/apache/pulsar/client/api/url/DataURLStreamHandler.html" title="class in org.apache.pulsar.client.api.url">DataURLStreamHandler</a></li>
<li><a href="org/apache/pulsar/client/api/EncodedAuthenticationParameterSupport.html" title="interface in org.apache.pulsar.client.api"><span class="interfaceName">EncodedAuthenticationParameterSupport</span></a></li>
<li><a href="org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api">EncryptionKeyInfo</a></li>
+<li><a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a></li>
<li><a href="org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api"><span class="interfaceName">Message</span></a></li>
<li><a href="org/apache/pulsar/client/api/MessageBuilder.html" title="interface in org.apache.pulsar.client.api"><span class="interfaceName">MessageBuilder</span></a></li>
<li><a href="org/apache/pulsar/client/api/MessageId.html" title="interface in org.apache.pulsar.client.api"><span class="interfaceName">MessageId</span></a></li>
diff --git a/content/api/client/index-all.html b/content/api/client/index-all.html
index 2c2abd2..71b8ea1 100644
--- a/content/api/client/index-all.html
+++ b/content/api/client/index-all.html
@@ -483,10 +483,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/EncryptionKeyInfo.html#EncryptionKeyInfo-byte:A-java.util.Map-">EncryptionKeyInfo(byte[], Map<String, String>)</a></span> - Constructor for class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api">EncryptionKeyInfo</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ProducerConfiguration.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ProducerConfiguration.html" title="class in org.apache.pulsar.client.api">ProducerConfiguration</a></dt>
-<dd>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
- </dd>
</dl>
<a name="I:F">
<!-- -->
@@ -542,6 +538,14 @@
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
<div class="block">Get configured total allowed concurrent lookup-request.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ClientConfiguration.html#getConfigurationData--">getConfigurationData()</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"><span class="deprecatedLabel">Deprecated.</span></div>
+ </dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ConsumerConfiguration.html#getConfigurationData--">getConfigurationData()</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></dt>
+<dd>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
+ </dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ClientConfiguration.html#getConnectionsPerBroker--">getConnectionsPerBroker()</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"><span class="deprecatedLabel">Deprecated.</span></div>
@@ -678,6 +682,10 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/CryptoKeyReader.html#getPrivateKey-java.lang.String-java.util.Map-">getPrivateKey(String, Map<String, String>)</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ProducerConfiguration.html#getProducerConfigurationData--">getProducerConfigurationData()</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ProducerConfiguration.html" title="class in org.apache.pulsar.client.api">ProducerConfiguration</a></dt>
+<dd>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
+ </dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/Message.html#getProducerName--">getProducerName()</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api">Message</a></dt>
<dd>
<div class="block">Get the producer name who produced this message.</div>
@@ -716,6 +724,10 @@
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ReaderConfiguration.html#getReaderConfigurationData--">getReaderConfigurationData()</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></dt>
+<dd>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
+ </dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ReaderConfiguration.html#getReaderListener--">getReaderListener()</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
@@ -812,6 +824,14 @@
<dd>
<div class="block">Check if data from Pulsar protocol are available.</div>
</dd>
+<dt><a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">HashingScheme</span></a> - Enum in <a href="org/apache/pulsar/client/api/package-summary.html">org.apache.pulsar.client.api</a></dt>
+<dd>
+<div class="block">Standard hashing functions available when choosing the partition to use for a particular message.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ProducerBuilder.html#hashingScheme-org.apache.pulsar.client.api.HashingScheme-">hashingScheme(HashingScheme)</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></dt>
+<dd>
+<div class="block">Change the <a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><code>HashingScheme</code></a> used to chose the partition on where to publish a particular message.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/Message.html#hasKey--">hasKey()</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api">Message</a></dt>
<dd>
<div class="block">Check whether the message has a key</div>
@@ -953,10 +973,12 @@
<div class="block">Set a custom message routing policy by passing an implementation of MessageRouter</div>
</dd>
<dt><a href="org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">MessageRoutingMode</span></a> - Enum in <a href="org/apache/pulsar/client/api/package-summary.html">org.apache.pulsar.client.api</a></dt>
-<dd> </dd>
+<dd>
+<div class="block">Default routing mode for messages to partition.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ProducerBuilder.html#messageRoutingMode-org.apache.pulsar.client.api.MessageRoutingMode-">messageRoutingMode(MessageRoutingMode)</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></dt>
<dd>
-<div class="block">Set the message routing mode for the partitioned producer</div>
+<div class="block">Set the message routing mode for the partitioned producer.</div>
</dd>
</dl>
<a name="I:N">
@@ -1492,8 +1514,8 @@
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ConsumerConfiguration.html#setReadCompacted-boolean-">setReadCompacted(boolean)</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
-<div class="block">If enabled, the consumer will read messages from the compacted topic rather than reading the full message
- backlog of the topic.</div>
+<div class="block">If enabled, the consumer will read messages from the compacted topic rather than reading the full message backlog
+ of the topic.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ReaderConfiguration.html#setReaderListener-org.apache.pulsar.client.api.ReaderListener-">setReaderListener(ReaderListener)</a></span> - Method in class org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></dt>
<dd>
@@ -1528,6 +1550,10 @@
<dd>
<div class="block">Specify a custom sequence id for the message being published.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ClientConfiguration.html#setServiceUrl-java.lang.String-">setServiceUrl(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"><span class="deprecatedLabel">Deprecated.</span></div>
+ </dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/ClientConfiguration.html#setStatsInterval-long-java.util.concurrent.TimeUnit-">setStatsInterval(long, TimeUnit)</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"><span class="deprecatedLabel">Deprecated.</span></div>
@@ -1701,6 +1727,10 @@
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/HashingScheme.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a></dt>
+<dd>
+<div class="block">Returns the enum constant of this type with the specified name.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/MessageRoutingMode.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a></dt>
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
@@ -1733,6 +1763,11 @@ the order they are declared.</div>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/HashingScheme.html#values--">values()</a></span> - Static method in enum org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a></dt>
+<dd>
+<div class="block">Returns an array containing the constants of this enum type, in
+the order they are declared.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/MessageRoutingMode.html#values--">values()</a></span> - Static method in enum org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a></dt>
<dd>
<div class="block">Returns an array containing the constants of this enum type, in
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 3228364..76b94fa 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":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":42,"i11":42,"i12":42,"i13":42,"i14":42,"i15":42,"i16":42,"i17":42,"i18":42,"i19":42,"i20":42,"i21":42,"i22":42,"i23":42,"i24":42,"i25":42,"i26":42,"i27":42};
+var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":42,"i11":42,"i12":42,"i13":42,"i14":42,"i15":42,"i16":42,"i17":42,"i18":42,"i19":42,"i20":42,"i21":42,"i22":42,"i23":42,"i24":42,"i25":42,"i26":42,"i27":42,"i28":42,"i29":42};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -174,81 +174,87 @@ implements Serializable</pre>
</td>
</tr>
<tr id="i2" class="altColor">
+<td class="colFirst"><code>ClientConfigurationData</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getConfigurationData--">getConfigurationData</a></span>()</code>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+ </td>
+</tr>
+<tr id="i3" class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getConnectionsPerBroker--">getConnectionsPerBroker</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i3" class="rowColor">
+<tr id="i4" class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getIoThreads--">getIoThreads</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getListenerThreads--">getListenerThreads</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getMaxNumberOfRejectedRequestPerConnection--">getMaxNumberOfRejectedRequestPerConnection</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Get configured max number of reject-request in a time-frame (30 seconds) after which connection will be closed</div>
</td>
</tr>
-<tr id="i6" class="altColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code>long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getOperationTimeoutMs--">getOperationTimeoutMs</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code>long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getStatsIntervalSeconds--">getStatsIntervalSeconds</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Stats will be activated with positive statsIntervalSeconds</div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code>String</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#getTlsTrustCertsFilePath--">getTlsTrustCertsFilePath</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<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#isTlsAllowInsecureConnection--">isTlsAllowInsecureConnection</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i10" class="altColor">
+<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#isTlsHostnameVerificationEnable--">isTlsHostnameVerificationEnable</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i11" class="rowColor">
+<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#isUseTcpNoDelay--">isUseTcpNoDelay</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i12" class="altColor">
+<tr id="i13" 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>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </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-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"><span class="deprecatedLabel">Deprecated.</span> </div>
<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.util.Map-">setAuthentication</a></span>(String authPluginClassName,
Map<String,String> authParams)</code>
@@ -256,7 +262,7 @@ implements Serializable</pre>
<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#setAuthentication-java.lang.String-java.lang.String-">setAuthentication</a></span>(String authPluginClassName,
String authParamsString)</code>
@@ -264,35 +270,35 @@ implements Serializable</pre>
<div class="block">Set the authentication provider to use in the Pulsar client instance.</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#setConcurrentLookupRequest-int-">setConcurrentLookupRequest</a></span>(int concurrentLookupRequest)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Number of concurrent lookup-requests allowed on each broker-connection to prevent overload on 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#setConnectionsPerBroker-int-">setConnectionsPerBroker</a></span>(int connectionsPerBroker)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets the max number of connection that the client library will open to a single broker.</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#setIoThreads-int-">setIoThreads</a></span>(int numIoThreads)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<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="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#setListenerThreads-int-">setListenerThreads</a></span>(int numListenerThreads)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Set the number of threads to be used for message listeners <i>(default: 1 thread)</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#setMaxNumberOfRejectedRequestPerConnection-int-">setMaxNumberOfRejectedRequestPerConnection</a></span>(int maxNumberOfRejectedRequestPerConnection)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
@@ -301,7 +307,7 @@ implements Serializable</pre>
50)</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#setOperationTimeout-int-java.util.concurrent.TimeUnit-">setOperationTimeout</a></span>(int operationTimeout,
TimeUnit unit)</code>
@@ -309,7 +315,13 @@ implements Serializable</pre>
<div class="block">Set the operation timeout <i>(default: 30 seconds)</i></div>
</td>
</tr>
-<tr id="i22" class="altColor">
+<tr id="i23" class="rowColor">
+<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html" title="class in org.apache.pulsar.client.api">ClientConfiguration</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html#setServiceUrl-java.lang.String-">setServiceUrl</a></span>(String serviceUrl)</code>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+ </td>
+</tr>
+<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#setStatsInterval-long-java.util.concurrent.TimeUnit-">setStatsInterval</a></span>(long statsInterval,
TimeUnit unit)</code>
@@ -318,35 +330,35 @@ implements Serializable</pre>
statsIntervalSeconds It should be set to at least 1 second</div>
</td>
</tr>
-<tr id="i23" class="rowColor">
+<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#setTlsAllowInsecureConnection-boolean-">setTlsAllowInsecureConnection</a></span>(boolean tlsAllowInsecureConnection)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Configure whether the Pulsar client accept untrusted TLS certificate from broker <i>(default: false)</i></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#setTlsHostnameVerificationEnable-boolean-">setTlsHostnameVerificationEnable</a></span>(boolean tlsHostnameVerificationEnable)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">It allows to validate hostname verification when client connects to broker over tls.</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#setTlsTrustCertsFilePath-java.lang.String-">setTlsTrustCertsFilePath</a></span>(String tlsTrustCertsFilePath)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Set the path to the trusted TLS certificate file</div>
</td>
</tr>
-<tr id="i26" class="altColor">
+<tr id="i28" 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"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Configure whether to use TCP no-delay flag on the connection, to disable Nagle algorithm.</div>
</td>
</tr>
-<tr id="i27" class="rowColor">
+<tr id="i29" 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"><span class="deprecatedLabel">Deprecated.</span> </div>
@@ -422,12 +434,12 @@ implements Serializable</pre>
<pre>
<code>
- ClientConfiguration conf = new ClientConfiguration();
+ ClientConfiguration confData = new ClientConfiguration();
String authPluginClassName = "org.apache.pulsar.client.impl.auth.MyAuthentication";
String authParamsString = "key1:val1,key2:val2";
Authentication auth = AuthenticationFactory.create(authPluginClassName, authParamsString);
- conf.setAuthentication(auth);
- PulsarClient client = PulsarClient.create(serviceUrl, conf);
+ confData.setAuthentication(auth);
+ PulsarClient client = PulsarClient.create(serviceUrl, confData);
....
</code>
</pre></div>
@@ -454,11 +466,11 @@ implements Serializable</pre>
<pre>
<code>
- ClientConfiguration conf = new ClientConfiguration();
+ ClientConfiguration confData = new ClientConfiguration();
String authPluginClassName = "org.apache.pulsar.client.impl.auth.MyAuthentication";
String authParamsString = "key1:val1,key2:val2";
- conf.setAuthentication(authPluginClassName, authParamsString);
- PulsarClient client = PulsarClient.create(serviceUrl, conf);
+ confData.setAuthentication(authPluginClassName, authParamsString);
+ PulsarClient client = PulsarClient.create(serviceUrl, confData);
....
</code>
</pre></div>
@@ -488,12 +500,12 @@ implements Serializable</pre>
<pre>
<code>
- ClientConfiguration conf = new ClientConfiguration();
+ ClientConfiguration confData = new ClientConfiguration();
String authPluginClassName = "org.apache.pulsar.client.impl.auth.MyAuthentication";
Map<String, String> authParams = new HashMap<String, String>();
authParams.put("key1", "val1");
- conf.setAuthentication(authPluginClassName, authParams);
- PulsarClient client = PulsarClient.create(serviceUrl, conf);
+ confData.setAuthentication(authPluginClassName, authParams);
+ PulsarClient client = PulsarClient.create(serviceUrl, confData);
....
</code>
</pre></div>
@@ -809,8 +821,8 @@ implements Serializable</pre>
<pre>public void setConcurrentLookupRequest(int concurrentLookupRequest)</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Number of concurrent lookup-requests allowed on each broker-connection to prevent overload on broker.
- <i>(default: 50000)</i> It should be configured with higher value only in case of it requires to produce/subscribe on
- thousands of topic using created <a href="../../../../../org/apache/pulsar/client/api/PulsarClient.html" title="interface in org.apache.pulsar.client.api"><code>PulsarClient</code></a></div>
+ <i>(default: 50000)</i> It should be configured with higher value only in case of it requires to
+ produce/subscribe on thousands of topic using created <a href="../../../../../org/apache/pulsar/client/api/PulsarClient.html" title="interface in org.apache.pulsar.client.api"><code>PulsarClient</code></a></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>concurrentLookupRequest</code> - </dd>
@@ -861,14 +873,14 @@ implements Serializable</pre>
<a name="setTlsHostnameVerificationEnable-boolean-">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>setTlsHostnameVerificationEnable</h4>
<pre>public void setTlsHostnameVerificationEnable(boolean tlsHostnameVerificationEnable)</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<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>
+ 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>
@@ -877,6 +889,26 @@ implements Serializable</pre>
</dl>
</li>
</ul>
+<a name="setServiceUrl-java.lang.String-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>setServiceUrl</h4>
+<pre>public <a href="../../../../../org/apache/pulsar/client/api/ClientConfiguration.html" title="class in org.apache.pulsar.client.api">ClientConfiguration</a> setServiceUrl(String serviceUrl)</pre>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+</li>
+</ul>
+<a name="getConfigurationData--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>getConfigurationData</h4>
+<pre>public ClientConfigurationData getConfigurationData()</pre>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+</li>
+</ul>
</li>
</ul>
</li>
diff --git a/content/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html b/content/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html
index 3e9e668..fd99e85 100644
--- a/content/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html
+++ b/content/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":42,"i11":42,"i12":42,"i13":42,"i14":42,"i15":42,"i16":42,"i17":42,"i18":42,"i19":42,"i20":42,"i21":42,"i22":42,"i23":42,"i24":42};
+var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":42,"i11":42,"i12":42,"i13":42,"i14":42,"i15":42,"i16":42,"i17":42,"i18":42,"i19":42,"i20":42,"i21":42,"i22":42,"i23":42,"i24":42,"i25":42};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -169,72 +169,78 @@ implements Serializable</pre>
</td>
</tr>
<tr id="i1" class="rowColor">
+<td class="colFirst"><code>ConsumerConfigurationData</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getConfigurationData--">getConfigurationData</a></span>()</code>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+ </td>
+</tr>
+<tr id="i2" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerEventListener.html" title="interface in org.apache.pulsar.client.api">ConsumerEventListener</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getConsumerEventListener--">getConsumerEventListener</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i2" class="altColor">
+<tr id="i3" class="rowColor">
<td class="colFirst"><code>String</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getConsumerName--">getConsumerName</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i3" class="rowColor">
+<tr id="i4" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ConsumerCryptoFailureAction</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getCryptoFailureAction--">getCryptoFailureAction</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getCryptoKeyReader--">getCryptoKeyReader</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getMaxTotalReceiverQueueSizeAcrossPartitions--">getMaxTotalReceiverQueueSizeAcrossPartitions</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i6" class="altColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/MessageListener.html" title="interface in org.apache.pulsar.client.api">MessageListener</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getMessageListener--">getMessageListener</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getPriorityLevel--">getPriorityLevel</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code>Map<String,String></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getProperties--">getProperties</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<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/ConsumerConfiguration.html#getReadCompacted--">getReadCompacted</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i10" class="altColor">
+<tr id="i11" class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getReceiverQueueSize--">getReceiverQueueSize</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i11" class="rowColor">
+<tr id="i12" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/SubscriptionType.html" title="enum in org.apache.pulsar.client.api">SubscriptionType</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#getSubscriptionType--">getSubscriptionType</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i12" class="altColor">
+<tr id="i13" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setAckTimeout-long-java.util.concurrent.TimeUnit-">setAckTimeout</a></span>(long ackTimeout,
TimeUnit timeUnit)</code>
@@ -242,49 +248,49 @@ implements Serializable</pre>
<div class="block">Set the timeout for unacked messages, truncated to the nearest millisecond.</div>
</td>
</tr>
-<tr id="i13" class="rowColor">
+<tr id="i14" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setConsumerEventListener-org.apache.pulsar.client.api.ConsumerEventListener-">setConsumerEventListener</a></span>(<a href="../../../../../org/apache/pulsar/client/api/ConsumerEventListener.html" title="interface in org.apache.pulsar.client.api">ConsumerEventListener</a> listener)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets a <a href="../../../../../org/apache/pulsar/client/api/ConsumerEventListener.html" title="interface in org.apache.pulsar.client.api"><code>ConsumerEventListener</code></a> for the consumer.</div>
</td>
</tr>
-<tr id="i14" class="altColor">
+<tr id="i15" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setConsumerName-java.lang.String-">setConsumerName</a></span>(String consumerName)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Set the consumer name.</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/ConsumerConfiguration.html#setCryptoFailureAction-org.apache.pulsar.client.api.ConsumerCryptoFailureAction-">setCryptoFailureAction</a></span>(<a href="../../../../../org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ConsumerCryptoFailureAction</a> action)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets the ConsumerCryptoFailureAction to the value specified</div>
</td>
</tr>
-<tr id="i16" class="altColor">
+<tr id="i17" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setCryptoKeyReader-org.apache.pulsar.client.api.CryptoKeyReader-">setCryptoKeyReader</a></span>(<a href="../../../../../org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a> cryptoKeyReader)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets a <a href="../../../../../org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api"><code>CryptoKeyReader</code></a></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/ConsumerConfiguration.html#setMaxTotalReceiverQueueSizeAcrossPartitions-int-">setMaxTotalReceiverQueueSizeAcrossPartitions</a></span>(int maxTotalReceiverQueueSizeAcrossPartitions)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Set the max total receiver queue size across partitons.</div>
</td>
</tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setMessageListener-org.apache.pulsar.client.api.MessageListener-">setMessageListener</a></span>(<a href="../../../../../org/apache/pulsar/client/api/MessageListener.html" title="interface in org.apache.pulsar.client.api">MessageListener</a> messageListener)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets a <a href="../../../../../org/apache/pulsar/client/api/MessageListener.html" title="interface in org.apache.pulsar.client.api"><code>MessageListener</code></a> for the consumer</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/ConsumerConfiguration.html#setPriorityLevel-int-">setPriorityLevel</a></span>(int priorityLevel)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
@@ -292,14 +298,14 @@ implements Serializable</pre>
messages.</div>
</td>
</tr>
-<tr id="i20" class="altColor">
+<tr id="i21" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setProperties-java.util.Map-">setProperties</a></span>(Map<String,String> properties)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Add all the properties in the provided map</div>
</td>
</tr>
-<tr id="i21" class="rowColor">
+<tr id="i22" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setProperty-java.lang.String-java.lang.String-">setProperty</a></span>(String key,
String value)</code>
@@ -307,22 +313,22 @@ implements Serializable</pre>
<div class="block">Set a name/value property with this consumer.</div>
</td>
</tr>
-<tr id="i22" class="altColor">
+<tr id="i23" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setReadCompacted-boolean-">setReadCompacted</a></span>(boolean readCompacted)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-<div class="block">If enabled, the consumer will read messages from the compacted topic rather than reading the full message
- backlog of the topic.</div>
+<div class="block">If enabled, the consumer will read messages from the compacted topic rather than reading the full message backlog
+ of the topic.</div>
</td>
</tr>
-<tr id="i23" class="rowColor">
+<tr id="i24" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setReceiverQueueSize-int-">setReceiverQueueSize</a></span>(int receiverQueueSize)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets the size of the consumer receive queue.</div>
</td>
</tr>
-<tr id="i24" class="altColor">
+<tr id="i25" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html#setSubscriptionType-org.apache.pulsar.client.api.SubscriptionType-">setSubscriptionType</a></span>(<a href="../../../../../org/apache/pulsar/client/api/SubscriptionType.html" title="enum in org.apache.pulsar.client.api">SubscriptionType</a> subscriptionType)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
@@ -494,10 +500,12 @@ implements Serializable</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets a <a href="../../../../../org/apache/pulsar/client/api/ConsumerEventListener.html" title="interface in org.apache.pulsar.client.api"><code>ConsumerEventListener</code></a> for the consumer.
- <p>The consumer group listener is used for receiving consumer state change in a consumer group for failover
+ <p>
+ The consumer group listener is used for receiving consumer state change in a consumer group for failover
subscription. Application can then react to the consumer state changes.
- <p>This change is experimental. It is subject to changes coming in release 2.0.</div>
+ <p>
+ This change is experimental. It is subject to changes coming in release 2.0.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>listener</code> - the consumer group listener object</dd>
@@ -734,14 +742,14 @@ implements Serializable</pre>
<h4>setReadCompacted</h4>
<pre>public <a href="../../../../../org/apache/pulsar/client/api/ConsumerConfiguration.html" title="class in org.apache.pulsar.client.api">ConsumerConfiguration</a> setReadCompacted(boolean readCompacted)</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-<div class="block">If enabled, the consumer will read messages from the compacted topic rather than reading the full message
- backlog of the topic. This means that, if the topic has been compacted, the consumer will only see the latest
- value for each key in the topic, up until the point in the topic message backlog that has been compacted.
- Beyond that point, the messages will be sent as normal.
+<div class="block">If enabled, the consumer will read messages from the compacted topic rather than reading the full message backlog
+ of the topic. This means that, if the topic has been compacted, the consumer will only see the latest value for
+ each key in the topic, up until the point in the topic message backlog that has been compacted. Beyond that
+ point, the messages will be sent as normal.
- readCompacted can only be enabled subscriptions to persistent topics, which have a single active consumer
- (i.e. failure or exclusive subscriptions). Attempting to enable it on subscriptions to a non-persistent
- topics or on a shared subscription, will lead to the subscription call throwing a PulsarClientException.</div>
+ readCompacted can only be enabled subscriptions to persistent topics, which have a single active consumer (i.e.
+ failure or exclusive subscriptions). Attempting to enable it on subscriptions to a non-persistent topics or on a
+ shared subscription, will lead to the subscription call throwing a PulsarClientException.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>readCompacted</code> - whether to read from the compacted topic</dd>
@@ -785,13 +793,23 @@ implements Serializable</pre>
<a name="getProperties--">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>getProperties</h4>
<pre>public Map<String,String> getProperties()</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</li>
</ul>
+<a name="getConfigurationData--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>getConfigurationData</h4>
+<pre>public ConsumerConfigurationData getConfigurationData()</pre>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+</li>
+</ul>
</li>
</ul>
</li>
diff --git a/content/api/client/org/apache/pulsar/client/api/EncryptionKeyInfo.html b/content/api/client/org/apache/pulsar/client/api/EncryptionKeyInfo.html
index 3d29fb0..5f9fc52 100644
--- a/content/api/client/org/apache/pulsar/client/api/EncryptionKeyInfo.html
+++ b/content/api/client/org/apache/pulsar/client/api/EncryptionKeyInfo.html
@@ -48,7 +48,7 @@ var activeTableTab = "activeTableTab";
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/pulsar/client/api/EncodedAuthenticationParameterSupport.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/pulsar/client/api/EncryptionKeyInfo.html" target="_top">Frames</a></li>
@@ -277,7 +277,7 @@ extends Object</pre>
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/pulsar/client/api/EncodedAuthenticationParameterSupport.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/pulsar/client/api/EncryptionKeyInfo.html" target="_top">Frames</a></li>
diff --git a/content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html b/content/api/client/org/apache/pulsar/client/api/HashingScheme.html
similarity index 74%
copy from content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html
copy to content/api/client/org/apache/pulsar/client/api/HashingScheme.html
index 6e1fe9f..83220bb 100644
--- a/content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html
+++ b/content/api/client/org/apache/pulsar/client/api/HashingScheme.html
@@ -3,7 +3,7 @@
<html lang="en">
<head>
<!-- Generated by javadoc -->
-<title>MessageRoutingMode (Pulsar Client Java API)</title>
+<title>HashingScheme (Pulsar Client Java API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -11,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MessageRoutingMode (Pulsar Client Java API)";
+ parent.document.title="HashingScheme (Pulsar Client Java API)";
}
}
catch(err) {
@@ -47,12 +47,12 @@ var activeTableTab = "activeTableTab";
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../org/apache/pulsar/client/api/MessageRouter.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/pulsar/client/api/Producer.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/pulsar/client/api/MessageRoutingMode.html" target="_top">Frames</a></li>
-<li><a href="MessageRoutingMode.html" target="_top">No Frames</a></li>
+<li><a href="../../../../../index.html?org/apache/pulsar/client/api/HashingScheme.html" target="_top">Frames</a></li>
+<li><a href="HashingScheme.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
@@ -91,17 +91,17 @@ var activeTableTab = "activeTableTab";
<!-- ======== START OF CLASS DATA ======== -->
<div class="header">
<div class="subTitle">org.apache.pulsar.client.api</div>
-<h2 title="Enum MessageRoutingMode" class="title">Enum MessageRoutingMode</h2>
+<h2 title="Enum HashingScheme" class="title">Enum HashingScheme</h2>
</div>
<div class="contentContainer">
<ul class="inheritance">
<li>Object</li>
<li>
<ul class="inheritance">
-<li>Enum<<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a>></li>
+<li>Enum<<a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a>></li>
<li>
<ul class="inheritance">
-<li>org.apache.pulsar.client.api.MessageRoutingMode</li>
+<li>org.apache.pulsar.client.api.HashingScheme</li>
</ul>
</li>
</ul>
@@ -112,12 +112,13 @@ var activeTableTab = "activeTableTab";
<li class="blockList">
<dl>
<dt>All Implemented Interfaces:</dt>
-<dd>Serializable, Comparable<<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a>></dd>
+<dd>Serializable, Comparable<<a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a>></dd>
</dl>
<hr>
<br>
-<pre>public enum <span class="typeNameLabel">MessageRoutingMode</span>
-extends Enum<<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a>></pre>
+<pre>public enum <span class="typeNameLabel">HashingScheme</span>
+extends Enum<<a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a>></pre>
+<div class="block">Standard hashing functions available when choosing the partition to use for a particular message.</div>
</li>
</ul>
</div>
@@ -136,13 +137,14 @@ extends Enum<<a href="../../../../../org/apache/pulsar/client/api/MessageRout
<th class="colOne" scope="col">Enum Constant and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#CustomPartition">CustomPartition</a></span></code> </td>
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html#JavaStringHash">JavaStringHash</a></span></code>
+<div class="block">Use regural <code>String.hashCode()</code></div>
+</td>
</tr>
<tr class="rowColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#RoundRobinPartition">RoundRobinPartition</a></span></code> </td>
-</tr>
-<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#SinglePartition">SinglePartition</a></span></code> </td>
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html#Murmur3_32Hash">Murmur3_32Hash</a></span></code>
+<div class="block">Use Murmur3 hashing function.</div>
+</td>
</tr>
</table>
</li>
@@ -160,14 +162,14 @@ extends Enum<<a href="../../../../../org/apache/pulsar/client/api/MessageRout
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr id="i0" class="altColor">
-<td class="colFirst"><code>static <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#valueOf-java.lang.String-">valueOf</a></span>(String name)</code>
+<td class="colFirst"><code>static <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html#valueOf-java.lang.String-">valueOf</a></span>(String name)</code>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</td>
</tr>
<tr id="i1" class="rowColor">
-<td class="colFirst"><code>static <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a>[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#values--">values</a></span>()</code>
+<td class="colFirst"><code>static <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a>[]</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html#values--">values</a></span>()</code>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared.</div>
</td>
@@ -201,31 +203,25 @@ the order they are declared.</div>
<!-- -->
</a>
<h3>Enum Constant Detail</h3>
-<a name="SinglePartition">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>SinglePartition</h4>
-<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> SinglePartition</pre>
-</li>
-</ul>
-<a name="RoundRobinPartition">
+<a name="JavaStringHash">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>RoundRobinPartition</h4>
-<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> RoundRobinPartition</pre>
+<h4>JavaStringHash</h4>
+<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a> JavaStringHash</pre>
+<div class="block">Use regural <code>String.hashCode()</code></div>
</li>
</ul>
-<a name="CustomPartition">
+<a name="Murmur3_32Hash">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
-<h4>CustomPartition</h4>
-<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> CustomPartition</pre>
+<h4>Murmur3_32Hash</h4>
+<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a> Murmur3_32Hash</pre>
+<div class="block">Use Murmur3 hashing function.
+ <a href="https://en.wikipedia.org/wiki/MurmurHash">https://en.wikipedia.org/wiki/MurmurHash</a></div>
</li>
</ul>
</li>
@@ -242,12 +238,12 @@ the order they are declared.</div>
<ul class="blockList">
<li class="blockList">
<h4>values</h4>
-<pre>public static <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a>[] values()</pre>
+<pre>public static <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a>[] values()</pre>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared. This method may be used to iterate
over the constants as follows:
<pre>
-for (MessageRoutingMode c : MessageRoutingMode.values())
+for (HashingScheme c : HashingScheme.values())
System.out.println(c);
</pre></div>
<dl>
@@ -262,7 +258,7 @@ for (MessageRoutingMode c : MessageRoutingMode.values())
<ul class="blockListLast">
<li class="blockList">
<h4>valueOf</h4>
-<pre>public static <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> valueOf(String name)</pre>
+<pre>public static <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a> valueOf(String name)</pre>
<div class="block">Returns the enum constant of this type with the specified name.
The string must match <i>exactly</i> an identifier used to declare an
enum constant in this type. (Extraneous whitespace characters are
@@ -305,12 +301,12 @@ not permitted.)</div>
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../org/apache/pulsar/client/api/MessageRouter.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/pulsar/client/api/Producer.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/pulsar/client/api/MessageRoutingMode.html" target="_top">Frames</a></li>
-<li><a href="MessageRoutingMode.html" target="_top">No Frames</a></li>
+<li><a href="../../../../../index.html?org/apache/pulsar/client/api/HashingScheme.html" target="_top">Frames</a></li>
+<li><a href="HashingScheme.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
diff --git a/content/api/client/org/apache/pulsar/client/api/Message.html b/content/api/client/org/apache/pulsar/client/api/Message.html
index 62c99f3..32e1a47 100644
--- a/content/api/client/org/apache/pulsar/client/api/Message.html
+++ b/content/api/client/org/apache/pulsar/client/api/Message.html
@@ -47,7 +47,7 @@ var activeTableTab = "activeTableTab";
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
<li><a href="../../../../../org/apache/pulsar/client/api/MessageBuilder.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
@@ -405,7 +405,7 @@ var activeTableTab = "activeTableTab";
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../org/apache/pulsar/client/api/EncryptionKeyInfo.html" title="class in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">Prev Class</span></a></li>
<li><a href="../../../../../org/apache/pulsar/client/api/MessageBuilder.html" title="interface in org.apache.pulsar.client.api"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
diff --git a/content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html b/content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html
index 6e1fe9f..09d21fc 100644
--- a/content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html
+++ b/content/api/client/org/apache/pulsar/client/api/MessageRoutingMode.html
@@ -118,6 +118,10 @@ var activeTableTab = "activeTableTab";
<br>
<pre>public enum <span class="typeNameLabel">MessageRoutingMode</span>
extends Enum<<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a>></pre>
+<div class="block">Default routing mode for messages to partition.
+
+ This logic is applied when the application is not setting a key <a href="../../../../../org/apache/pulsar/client/api/MessageBuilder.html#setKey-java.lang.String-"><code>MessageBuilder.setKey(String)</code></a> on a particular
+ message.</div>
</li>
</ul>
</div>
@@ -136,13 +140,19 @@ extends Enum<<a href="../../../../../org/apache/pulsar/client/api/MessageRout
<th class="colOne" scope="col">Enum Constant and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#CustomPartition">CustomPartition</a></span></code> </td>
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#CustomPartition">CustomPartition</a></span></code>
+<div class="block">Use custom message router implemenation that will be called to determine the partition for a particular message.</div>
+</td>
</tr>
<tr class="rowColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#RoundRobinPartition">RoundRobinPartition</a></span></code> </td>
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#RoundRobinPartition">RoundRobinPartition</a></span></code>
+<div class="block">Publish messages across all partitions in round-robin.</div>
+</td>
</tr>
<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#SinglePartition">SinglePartition</a></span></code> </td>
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html#SinglePartition">SinglePartition</a></span></code>
+<div class="block">The producer will chose one single partition and publish all the messages into that partition.</div>
+</td>
</tr>
</table>
</li>
@@ -208,6 +218,7 @@ the order they are declared.</div>
<li class="blockList">
<h4>SinglePartition</h4>
<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> SinglePartition</pre>
+<div class="block">The producer will chose one single partition and publish all the messages into that partition.</div>
</li>
</ul>
<a name="RoundRobinPartition">
@@ -217,6 +228,7 @@ the order they are declared.</div>
<li class="blockList">
<h4>RoundRobinPartition</h4>
<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> RoundRobinPartition</pre>
+<div class="block">Publish messages across all partitions in round-robin.</div>
</li>
</ul>
<a name="CustomPartition">
@@ -226,6 +238,7 @@ the order they are declared.</div>
<li class="blockList">
<h4>CustomPartition</h4>
<pre>public static final <a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> CustomPartition</pre>
+<div class="block">Use custom message router implemenation that will be called to determine the partition for a particular message.</div>
</li>
</ul>
</li>
diff --git a/content/api/client/org/apache/pulsar/client/api/ProducerBuilder.html b/content/api/client/org/apache/pulsar/client/api/ProducerBuilder.html
index 5a3d908..1b1cde6 100644
--- a/content/api/client/org/apache/pulsar/client/api/ProducerBuilder.html
+++ b/content/api/client/org/apache/pulsar/client/api/ProducerBuilder.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":6,"i19":6,"i20":6};
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":6,"i19":6,"i20":6,"i21":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -199,61 +199,67 @@ extends Serializable, Cloneable</pre>
</tr>
<tr id="i11" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#hashingScheme-org.apache.pulsar.client.api.HashingScheme-">hashingScheme</a></span>(<a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a> hashingScheme)</code>
+<div class="block">Change the <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><code>HashingScheme</code></a> used to chose the partition on where to publish a particular message.</div>
+</td>
+</tr>
+<tr id="i12" class="altColor">
+<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#initialSequenceId-long-">initialSequenceId</a></span>(long initialSequenceId)</code>
<div class="block">Set the baseline for the sequence ids for messages published by the producer.</div>
</td>
</tr>
-<tr id="i12" class="altColor">
+<tr id="i13" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#maxPendingMessages-int-">maxPendingMessages</a></span>(int maxPendingMessages)</code>
<div class="block">Set the max size of the queue holding the messages pending to receive an acknowledgment from the broker.</div>
</td>
</tr>
-<tr id="i13" class="rowColor">
+<tr id="i14" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#maxPendingMessagesAcrossPartitions-int-">maxPendingMessagesAcrossPartitions</a></span>(int maxPendingMessagesAcrossPartitions)</code>
<div class="block">Set the number of max pending messages across all the partitions</div>
</td>
</tr>
-<tr id="i14" class="altColor">
+<tr id="i15" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#messageRouter-org.apache.pulsar.client.api.MessageRouter-">messageRouter</a></span>(<a href="../../../../../org/apache/pulsar/client/api/MessageRouter.html" title="interface in org.apache.pulsar.client.api">MessageRouter</a> messageRouter)</code>
<div class="block">Set a custom message routing policy by passing an implementation of MessageRouter</div>
</td>
</tr>
-<tr id="i15" class="rowColor">
+<tr id="i16" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#messageRoutingMode-org.apache.pulsar.client.api.MessageRoutingMode-">messageRoutingMode</a></span>(<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> messageRouteMode)</code>
-<div class="block">Set the message routing mode for the partitioned producer</div>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#messageRoutingMode-org.apache.pulsar.client.api.MessageRoutingMode-">messageRoutingMode</a></span>(<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> messageRoutingMode)</code>
+<div class="block">Set the message routing mode for the partitioned producer.</div>
</td>
</tr>
-<tr id="i16" class="altColor">
+<tr id="i17" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#producerName-java.lang.String-">producerName</a></span>(String producerName)</code>
<div class="block">Specify a name for the producer</div>
</td>
</tr>
-<tr id="i17" class="rowColor">
+<tr id="i18" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#properties-java.util.Map-">properties</a></span>(Map<String,String> properties)</code>
<div class="block">Add all the properties in the provided map</div>
</td>
</tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#property-java.lang.String-java.lang.String-">property</a></span>(String key,
String value)</code>
<div class="block">Set a name/value property with this producer.</div>
</td>
</tr>
-<tr id="i19" class="rowColor">
+<tr id="i20" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#sendTimeout-int-java.util.concurrent.TimeUnit-">sendTimeout</a></span>(int sendTimeout,
TimeUnit unit)</code>
<div class="block">Set the send timeout <i>(default: 30 seconds)</i></div>
</td>
</tr>
-<tr id="i20" class="altColor">
+<tr id="i21" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html#topic-java.lang.String-">topic</a></span>(String topicName)</code>
<div class="block">Specify the topic this producer will be publishing on.</div>
@@ -448,12 +454,39 @@ extends Serializable, Cloneable</pre>
<ul class="blockList">
<li class="blockList">
<h4>messageRoutingMode</h4>
-<pre><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a> messageRoutingMode(<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> messageRouteMode)</pre>
-<div class="block">Set the message routing mode for the partitioned producer</div>
+<pre><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a> messageRoutingMode(<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a> messageRoutingMode)</pre>
+<div class="block">Set the message routing mode for the partitioned producer.
+
+ Default routing mode for messages to partition.
+
+ This logic is applied when the application is not setting a key <a href="../../../../../org/apache/pulsar/client/api/MessageBuilder.html#setKey-java.lang.String-"><code>MessageBuilder.setKey(String)</code></a> on a
+ particular message.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>mode</code> - </dd>
-<dt><span class="returnLabel">Returns:</span></dt>
+<dd><code>messageRoutingMode</code> - the message routing mode</dd>
+</dl>
+</li>
+</ul>
+<a name="hashingScheme-org.apache.pulsar.client.api.HashingScheme-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>hashingScheme</h4>
+<pre><a href="../../../../../org/apache/pulsar/client/api/ProducerBuilder.html" title="interface in org.apache.pulsar.client.api">ProducerBuilder</a> hashingScheme(<a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a> hashingScheme)</pre>
+<div class="block">Change the <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><code>HashingScheme</code></a> used to chose the partition on where to publish a particular message.
+
+ Standard hashing functions available are:
+ <ul>
+ <li><code>JavaStringHash</code>: Java <code>String.hashCode()</code>
+ <li><code>Murmur3_32Hash</code>: Use Murmur3 hashing function.
+ <a href="https://en.wikipedia.org/wiki/MurmurHash">https://en.wikipedia.org/wiki/MurmurHash</a>
+ </ul>
+
+ Default is <code>JavaStringHash</code>.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>hashingScheme</code> - the chosen <a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><code>HashingScheme</code></a></dd>
</dl>
</li>
</ul>
@@ -572,9 +605,9 @@ extends Serializable, Cloneable</pre>
<dd><code>timeUnit</code> - the time unit of the <code>batchDelay</code></dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dt><span class="seeLabel">See Also:</span></dt>
-<dd><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#batchingMaxMessages"><code>threshold is reached; all messages will be published as a single
+<dd><code>threshold is reached; all messages will be published as a single
batch message. The consumer will be delivered individual messages in the batch in the same order they were
- enqueued</code></a></dd>
+ enqueued</code></dd>
</dl>
</li>
</ul>
diff --git a/content/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html b/content/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html
index 6604f01..9aeeb1a 100644
--- a/content/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html
+++ b/content/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html
@@ -196,90 +196,84 @@ implements Serializable</pre>
</tr>
<tr id="i1" class="rowColor">
<td class="colFirst"><code>boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#equals-java.lang.Object-">equals</a></span>(Object obj)</code>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
- </td>
-</tr>
-<tr id="i2" class="altColor">
-<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getBatchingEnabled--">getBatchingEnabled</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i3" class="rowColor">
+<tr id="i2" class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getBatchingMaxMessages--">getBatchingMaxMessages</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i3" class="rowColor">
<td class="colFirst"><code>long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getBatchingMaxPublishDelayMs--">getBatchingMaxPublishDelayMs</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i4" class="altColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getBlockIfQueueFull--">getBlockIfQueueFull</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i6" class="altColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/CompressionType.html" title="enum in org.apache.pulsar.client.api">CompressionType</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getCompressionType--">getCompressionType</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ProducerCryptoFailureAction</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getCryptoFailureAction--">getCryptoFailureAction</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getCryptoKeyReader--">getCryptoKeyReader</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i9" class="rowColor">
-<td class="colFirst"><code><any></code></td>
+<tr id="i8" class="altColor">
+<td class="colFirst"><code>Set<String></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getEncryptionKeys--">getEncryptionKeys</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i10" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.HashingScheme.html" title="enum in org.apache.pulsar.client.api">ProducerConfiguration.HashingScheme</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getHashingScheme--">getHashingScheme</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i11" class="rowColor">
+<tr id="i10" class="altColor">
<td class="colFirst"><code>Optional<Long></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getInitialSequenceId--">getInitialSequenceId</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i12" class="altColor">
+<tr id="i11" class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getMaxPendingMessages--">getMaxPendingMessages</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i13" class="rowColor">
+<tr id="i12" class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getMaxPendingMessagesAcrossPartitions--">getMaxPendingMessagesAcrossPartitions</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i14" class="altColor">
+<tr id="i13" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/MessageRouter.html" title="interface in org.apache.pulsar.client.api">MessageRouter</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getMessageRouter--">getMessageRouter</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Get the message router set by <a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#setMessageRouter-org.apache.pulsar.client.api.MessageRouter-"><code>setMessageRouter(MessageRouter)</code></a>.</div>
</td>
</tr>
-<tr id="i15" class="rowColor">
+<tr id="i14" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/MessageRouter.html" title="interface in org.apache.pulsar.client.api">MessageRouter</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getMessageRouter-int-">getMessageRouter</a></span>(int numPartitions)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
@@ -288,13 +282,19 @@ implements Serializable</pre>
</div>
</td>
</tr>
-<tr id="i16" class="altColor">
+<tr id="i15" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">ProducerConfiguration.MessageRoutingMode</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getMessageRoutingMode--">getMessageRoutingMode</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Get the message routing mode for the partitioned producer</div>
</td>
</tr>
+<tr id="i16" class="altColor">
+<td class="colFirst"><code>ProducerConfigurationData</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getProducerConfigurationData--">getProducerConfigurationData</a></span>()</code>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+ </td>
+</tr>
<tr id="i17" class="rowColor">
<td class="colFirst"><code>String</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#getProducerName--">getProducerName</a></span>()</code>
@@ -455,7 +455,7 @@ implements Serializable</pre>
<!-- -->
</a>
<h3>Methods inherited from class Object</h3>
-<code>clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
</ul>
</li>
</ul>
@@ -874,7 +874,7 @@ public <a href="../../../../../org/apache/pulsar/client/api/MessageRouter.h
<ul class="blockList">
<li class="blockList">
<h4>getEncryptionKeys</h4>
-<pre>public <any> getEncryptionKeys()</pre>
+<pre>public Set<String> getEncryptionKeys()</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -985,9 +985,9 @@ public <a href="../../../../../org/apache/pulsar/client/api/MessageRouter.h
Make sure all the consumer applications have been updated to use this client version, before starting to
batch messages.</dd>
<dt><span class="seeLabel">See Also:</span></dt>
-<dd><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.html#batchingMaxMessages"><code>threshold is reached; all messages will be published as a single
+<dd><code>threshold is reached; all messages will be published as a single
batch message. The consumer will be delivered individual messages in the batch in the same order they were
- enqueued</code></a></dd>
+ enqueued</code></dd>
</dl>
</li>
</ul>
@@ -1099,18 +1099,14 @@ public <a href="../../../../../org/apache/pulsar/client/api/MessageRouter.h
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</li>
</ul>
-<a name="equals-java.lang.Object-">
+<a name="getProducerConfigurationData--">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
-<h4>equals</h4>
-<pre>public boolean equals(Object obj)</pre>
+<h4>getProducerConfigurationData</h4>
+<pre>public ProducerConfigurationData getProducerConfigurationData()</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
-<dd><code>equals</code> in class <code>Object</code></dd>
-</dl>
</li>
</ul>
</li>
diff --git a/content/api/client/org/apache/pulsar/client/api/ReaderConfiguration.html b/content/api/client/org/apache/pulsar/client/api/ReaderConfiguration.html
index cdec51e..8cf2911 100644
--- a/content/api/client/org/apache/pulsar/client/api/ReaderConfiguration.html
+++ b/content/api/client/org/apache/pulsar/client/api/ReaderConfiguration.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42};
+var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":42};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -172,52 +172,58 @@ implements Serializable</pre>
</td>
</tr>
<tr id="i2" class="altColor">
+<td class="colFirst"><code>ReaderConfigurationData</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#getReaderConfigurationData--">getReaderConfigurationData</a></span>()</code>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+ </td>
+</tr>
+<tr id="i3" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ReaderListener.html" title="interface in org.apache.pulsar.client.api">ReaderListener</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#getReaderListener--">getReaderListener</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i3" class="rowColor">
+<tr id="i4" class="altColor">
<td class="colFirst"><code>String</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#getReaderName--">getReaderName</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#getReceiverQueueSize--">getReceiverQueueSize</a></span>()</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#setCryptoFailureAction-org.apache.pulsar.client.api.ConsumerCryptoFailureAction-">setCryptoFailureAction</a></span>(<a href="../../../../../org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ConsumerCryptoFailureAction</a> action)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets the ConsumerCryptoFailureAction to the value specified</div>
</td>
</tr>
-<tr id="i6" class="altColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#setCryptoKeyReader-org.apache.pulsar.client.api.CryptoKeyReader-">setCryptoKeyReader</a></span>(<a href="../../../../../org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a> cryptoKeyReader)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets a <a href="../../../../../org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api"><code>CryptoKeyReader</code></a></div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#setReaderListener-org.apache.pulsar.client.api.ReaderListener-">setReaderListener</a></span>(<a href="../../../../../org/apache/pulsar/client/api/ReaderListener.html" title="interface in org.apache.pulsar.client.api">ReaderListener</a> readerListener)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Sets a <a href="../../../../../org/apache/pulsar/client/api/ReaderListener.html" title="interface in org.apache.pulsar.client.api"><code>ReaderListener</code></a> for the reader</div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#setReaderName-java.lang.String-">setReaderName</a></span>(String readerName)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
<div class="block">Set the consumer name.</div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<tr id="i10" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html#setReceiverQueueSize-int-">setReceiverQueueSize</a></span>(int receiverQueueSize)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
@@ -406,7 +412,7 @@ implements Serializable</pre>
<a name="setReaderName-java.lang.String-">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>setReaderName</h4>
<pre>public <a href="../../../../../org/apache/pulsar/client/api/ReaderConfiguration.html" title="class in org.apache.pulsar.client.api">ReaderConfiguration</a> setReaderName(String readerName)</pre>
@@ -418,6 +424,16 @@ implements Serializable</pre>
</dl>
</li>
</ul>
+<a name="getReaderConfigurationData--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>getReaderConfigurationData</h4>
+<pre>public ReaderConfigurationData getReaderConfigurationData()</pre>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
+</li>
+</ul>
</li>
</ul>
</li>
diff --git a/content/api/client/org/apache/pulsar/client/api/package-frame.html b/content/api/client/org/apache/pulsar/client/api/package-frame.html
index ffc6ce4..d182605 100644
--- a/content/api/client/org/apache/pulsar/client/api/package-frame.html
+++ b/content/api/client/org/apache/pulsar/client/api/package-frame.html
@@ -47,6 +47,7 @@
<ul title="Enums">
<li><a href="CompressionType.html" title="enum in org.apache.pulsar.client.api" target="classFrame">CompressionType</a></li>
<li><a href="ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api" target="classFrame">ConsumerCryptoFailureAction</a></li>
+<li><a href="HashingScheme.html" title="enum in org.apache.pulsar.client.api" target="classFrame">HashingScheme</a></li>
<li><a href="MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api" target="classFrame">MessageRoutingMode</a></li>
<li><a href="ProducerConfiguration.HashingScheme.html" title="enum in org.apache.pulsar.client.api" target="classFrame">ProducerConfiguration.HashingScheme</a></li>
<li><a href="ProducerConfiguration.MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api" target="classFrame">ProducerConfiguration.MessageRoutingMode</a></li>
diff --git a/content/api/client/org/apache/pulsar/client/api/package-summary.html b/content/api/client/org/apache/pulsar/client/api/package-summary.html
index feda8c7..f2a71bd 100644
--- a/content/api/client/org/apache/pulsar/client/api/package-summary.html
+++ b/content/api/client/org/apache/pulsar/client/api/package-summary.html
@@ -262,22 +262,30 @@
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a></td>
-<td class="colLast"> </td>
+<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api">HashingScheme</a></td>
+<td class="colLast">
+<div class="block">Standard hashing functions available when choosing the partition to use for a particular message.</div>
+</td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">MessageRoutingMode</a></td>
+<td class="colLast">
+<div class="block">Default routing mode for messages to partition.</div>
+</td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.HashingScheme.html" title="enum in org.apache.pulsar.client.api">ProducerConfiguration.HashingScheme</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">ProducerConfiguration.MessageRoutingMode</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/ProducerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ProducerCryptoFailureAction</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/pulsar/client/api/SubscriptionType.html" title="enum in org.apache.pulsar.client.api">SubscriptionType</a></td>
<td class="colLast">
<div class="block">Types of subscription supported by Pulsar</div>
diff --git a/content/api/client/org/apache/pulsar/client/api/package-tree.html b/content/api/client/org/apache/pulsar/client/api/package-tree.html
index 41ec1d0..05d19c2 100644
--- a/content/api/client/org/apache/pulsar/client/api/package-tree.html
+++ b/content/api/client/org/apache/pulsar/client/api/package-tree.html
@@ -189,6 +189,7 @@
<ul>
<li type="circle">org.apache.pulsar.client.api.<a href="../../../../../org/apache/pulsar/client/api/CompressionType.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">CompressionType</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="../../../../../org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">ConsumerCryptoFailureAction</span></a></li>
+<li type="circle">org.apache.pulsar.client.api.<a href="../../../../../org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">HashingScheme</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="../../../../../org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">MessageRoutingMode</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">ProducerConfiguration.HashingScheme</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="../../../../../org/apache/pulsar/client/api/ProducerConfiguration.MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">ProducerConfiguration.MessageRoutingMode</span></a></li>
diff --git a/content/api/client/overview-tree.html b/content/api/client/overview-tree.html
index 9353e28..9344298 100644
--- a/content/api/client/overview-tree.html
+++ b/content/api/client/overview-tree.html
@@ -197,6 +197,7 @@
<ul>
<li type="circle">org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/CompressionType.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">CompressionType</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">ConsumerCryptoFailureAction</span></a></li>
+<li type="circle">org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">HashingScheme</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">MessageRoutingMode</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ProducerConfiguration.HashingScheme.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">ProducerConfiguration.HashingScheme</span></a></li>
<li type="circle">org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/ProducerConfiguration.MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api"><span class="typeNameLink">ProducerConfiguration.MessageRoutingMode</span></a></li>
diff --git a/content/api/client/serialized-form.html b/content/api/client/serialized-form.html
index 76d7f14..05e9aa9 100644
--- a/content/api/client/serialized-form.html
+++ b/content/api/client/serialized-form.html
@@ -87,69 +87,9 @@
<li class="blockList">
<h3>Serialized Fields</h3>
<ul class="blockList">
-<li class="blockList">
-<h4>authentication</h4>
-<pre><a href="org/apache/pulsar/client/api/Authentication.html" title="interface in org.apache.pulsar.client.api">Authentication</a> authentication</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>operationTimeoutMs</h4>
-<pre>long operationTimeoutMs</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>statsIntervalSeconds</h4>
-<pre>long statsIntervalSeconds</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>numIoThreads</h4>
-<pre>int numIoThreads</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>numListenerThreads</h4>
-<pre>int numListenerThreads</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>connectionsPerBroker</h4>
-<pre>int connectionsPerBroker</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>useTcpNoDelay</h4>
-<pre>boolean useTcpNoDelay</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>useTls</h4>
-<pre>boolean useTls</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>tlsTrustCertsFilePath</h4>
-<pre>String tlsTrustCertsFilePath</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>tlsAllowInsecureConnection</h4>
-<pre>boolean tlsAllowInsecureConnection</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>tlsHostnameVerificationEnable</h4>
-<pre>boolean tlsHostnameVerificationEnable</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>concurrentLookupRequest</h4>
-<pre>int concurrentLookupRequest</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
<li class="blockListLast">
-<h4>maxNumberOfRejectedRequestPerConnection</h4>
-<pre>int maxNumberOfRejectedRequestPerConnection</pre>
+<h4>confData</h4>
+<pre>ClientConfigurationData confData</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</li>
</ul>
@@ -168,64 +108,9 @@
<li class="blockList">
<h3>Serialized Fields</h3>
<ul class="blockList">
-<li class="blockList">
-<h4>subscriptionType</h4>
-<pre><a href="org/apache/pulsar/client/api/SubscriptionType.html" title="enum in org.apache.pulsar.client.api">SubscriptionType</a> subscriptionType</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>messageListener</h4>
-<pre><a href="org/apache/pulsar/client/api/MessageListener.html" title="interface in org.apache.pulsar.client.api">MessageListener</a> messageListener</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>consumerEventListener</h4>
-<pre><a href="org/apache/pulsar/client/api/ConsumerEventListener.html" title="interface in org.apache.pulsar.client.api">ConsumerEventListener</a> consumerEventListener</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>receiverQueueSize</h4>
-<pre>int receiverQueueSize</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>maxTotalReceiverQueueSizeAcrossPartitions</h4>
-<pre>int maxTotalReceiverQueueSizeAcrossPartitions</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>consumerName</h4>
-<pre>String consumerName</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>ackTimeoutMillis</h4>
-<pre>long ackTimeoutMillis</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>priorityLevel</h4>
-<pre>int priorityLevel</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>cryptoKeyReader</h4>
-<pre><a href="org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a> cryptoKeyReader</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>cryptoFailureAction</h4>
-<pre><a href="org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ConsumerCryptoFailureAction</a> cryptoFailureAction</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>properties</h4>
-<pre>Map<K,V> properties</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
<li class="blockListLast">
-<h4>readCompacted</h4>
-<pre>boolean readCompacted</pre>
+<h4>conf</h4>
+<pre>ConsumerConfigurationData conf</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</li>
</ul>
@@ -244,89 +129,9 @@
<li class="blockList">
<h3>Serialized Fields</h3>
<ul class="blockList">
-<li class="blockList">
-<h4>producerName</h4>
-<pre>String producerName</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>sendTimeoutMs</h4>
-<pre>long sendTimeoutMs</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>blockIfQueueFull</h4>
-<pre>boolean blockIfQueueFull</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>maxPendingMessages</h4>
-<pre>int maxPendingMessages</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>maxPendingMessagesAcrossPartitions</h4>
-<pre>int maxPendingMessagesAcrossPartitions</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>messageRouteMode</h4>
-<pre><a href="org/apache/pulsar/client/api/ProducerConfiguration.MessageRoutingMode.html" title="enum in org.apache.pulsar.client.api">ProducerConfiguration.MessageRoutingMode</a> messageRouteMode</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>hashingScheme</h4>
-<pre><a href="org/apache/pulsar/client/api/ProducerConfiguration.HashingScheme.html" title="enum in org.apache.pulsar.client.api">ProducerConfiguration.HashingScheme</a> hashingScheme</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>customMessageRouter</h4>
-<pre><a href="org/apache/pulsar/client/api/MessageRouter.html" title="interface in org.apache.pulsar.client.api">MessageRouter</a> customMessageRouter</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>batchingMaxPublishDelayMs</h4>
-<pre>long batchingMaxPublishDelayMs</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>batchingMaxMessages</h4>
-<pre>int batchingMaxMessages</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>batchingEnabled</h4>
-<pre>boolean batchingEnabled</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>cryptoKeyReader</h4>
-<pre><a href="org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a> cryptoKeyReader</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>encryptionKeys</h4>
-<pre><any> encryptionKeys</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>compressionType</h4>
-<pre><a href="org/apache/pulsar/client/api/CompressionType.html" title="enum in org.apache.pulsar.client.api">CompressionType</a> compressionType</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>initialSequenceId</h4>
-<pre>Long initialSequenceId</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>properties</h4>
-<pre>Map<K,V> properties</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
<li class="blockListLast">
-<h4>cryptoFailureAction</h4>
-<pre><a href="org/apache/pulsar/client/api/ProducerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ProducerCryptoFailureAction</a> cryptoFailureAction</pre>
+<h4>conf</h4>
+<pre>ProducerConfigurationData conf</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</li>
</ul>
@@ -475,29 +280,9 @@
<li class="blockList">
<h3>Serialized Fields</h3>
<ul class="blockList">
-<li class="blockList">
-<h4>receiverQueueSize</h4>
-<pre>int receiverQueueSize</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>readerListener</h4>
-<pre><a href="org/apache/pulsar/client/api/ReaderListener.html" title="interface in org.apache.pulsar.client.api">ReaderListener</a> readerListener</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>readerName</h4>
-<pre>String readerName</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
-<li class="blockList">
-<h4>cryptoKeyReader</h4>
-<pre><a href="org/apache/pulsar/client/api/CryptoKeyReader.html" title="interface in org.apache.pulsar.client.api">CryptoKeyReader</a> cryptoKeyReader</pre>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
-</li>
<li class="blockListLast">
-<h4>cryptoFailureAction</h4>
-<pre><a href="org/apache/pulsar/client/api/ConsumerCryptoFailureAction.html" title="enum in org.apache.pulsar.client.api">ConsumerCryptoFailureAction</a> cryptoFailureAction</pre>
+<h4>conf</h4>
+<pre>ReaderConfigurationData conf</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span> </div>
</li>
</ul>
--
To stop receiving notification emails like this one, please contact
mmerli@apache.org.