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/06/12 08:29:56 UTC
[incubator-pulsar] branch asf-site updated: Updated site at
revision 673db8b
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 957d542 Updated site at revision 673db8b
957d542 is described below
commit 957d5421118a1d35502bf9abc63574267276600d
Author: jenkins <bu...@apache.org>
AuthorDate: Tue Jun 12 08:29:38 2018 +0000
Updated site at revision 673db8b
---
...spulsar_1_1_consumer_configuration-members.html | 20 ++++---
.../classpulsar_1_1_consumer_configuration.html | 6 ++
...asspulsar_1_1_reader_configuration-members.html | 8 ++-
.../cpp/classpulsar_1_1_reader_configuration.html | 6 ++
.../api/cpp/consumer__configuration_8h_source.html | 2 +-
.../api/cpp/reader__configuration_8h_source.html | 2 +-
content/api/python/index.html | 17 ++++--
.../docs/latest/cookbooks/compaction/index.html | 45 +++++----------
.../ConceptsAndArchitecture/index.html | 2 +-
.../docs/latest/project/BinaryProtocol/index.html | 14 +++++
content/docs/latest/reference/CliTools/index.html | 67 ++++++++++++++++++++++
content/ja/project/BinaryProtocol/index.html | 14 +++++
content/ja/reference/CliTools/index.html | 67 ++++++++++++++++++++++
13 files changed, 220 insertions(+), 50 deletions(-)
diff --git a/content/api/cpp/classpulsar_1_1_consumer_configuration-members.html b/content/api/cpp/classpulsar_1_1_consumer_configuration-members.html
index 0576b58..88b366d 100644
--- a/content/api/cpp/classpulsar_1_1_consumer_configuration-members.html
+++ b/content/api/cpp/classpulsar_1_1_consumer_configuration-members.html
@@ -108,15 +108,17 @@ var searchBox = new SearchBox("searchBox", "search",false,'Search');
<tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#ad07ae5670961401470b6e98541ddcbf7">getUnAckedMessagesTimeoutMs</a>() const </td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
<tr bgcolor="#f0f0f0"><td class="entry"><b>hasMessageListener</b>() const (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
<tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>isEncryptionEnabled</b>() const (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0"><td class="entry"><b>operator=</b>(const ConsumerConfiguration &) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>PulsarWrapper</b> (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"><span class="mlabel">friend</span></td></tr>
- <tr><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#a453a6af922fea7c45d56264d57925507">setBrokerConsumerStatsCacheTimeInMs</a>(const long cacheTimeInMs)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>setConsumerName</b>(const std::string &) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#ace6b2f1da486fcffacc4e877e5533268">setConsumerType</a>(ConsumerType consumerType)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>setCryptoFailureAction</b>(ConsumerCryptoFailureAction action) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0"><td class="entry"><b>setCryptoKeyReader</b>(CryptoKeyReaderPtr cryptoKeyReader) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#a9c07888abe996b80c2fd168278a24de3">setMaxTotalReceiverQueueSizeAcrossPartitions</a>(int maxTotalReceiverQueueSizeAcrossPartitions)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
- <tr><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#aeb4301821f8f471c6c542f486df9639d">setMessageListener</a>(MessageListener messageListener)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>isReadCompacted</b>() const (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>operator=</b>(const ConsumerConfiguration &) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>PulsarWrapper</b> (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"><span class="mlabel">friend</span></td></tr>
+ <tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#a453a6af922fea7c45d56264d57925507">setBrokerConsumerStatsCacheTimeInMs</a>(const long cacheTimeInMs)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>setConsumerName</b>(const std::string &) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#ace6b2f1da486fcffacc4e877e5533268">setConsumerType</a>(ConsumerType consumerType)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>setCryptoFailureAction</b>(ConsumerCryptoFailureAction action) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>setCryptoKeyReader</b>(CryptoKeyReaderPtr cryptoKeyReader) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#a9c07888abe996b80c2fd168278a24de3">setMaxTotalReceiverQueueSizeAcrossPartitions</a>(int maxTotalReceiverQueueSizeAcrossPartitions)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#aeb4301821f8f471c6c542f486df9639d">setMessageListener</a>(MessageListener messageListener)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>setReadCompacted</b>(bool compacted) (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
<tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#a265d2cd1e9d1d329eff9b98346f245c2">setReceiverQueueSize</a>(int size)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
<tr><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html#ad55a4f0187517c984de8d01f8660fb8f">setUnAckedMessagesTimeoutMs</a>(const uint64_t milliSeconds)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
<tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>~ConsumerConfiguration</b>() (defined in <a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_consumer_configuration.html">pulsar::ConsumerConfiguration</a></td><td class="entry"></td></tr>
diff --git a/content/api/cpp/classpulsar_1_1_consumer_configuration.html b/content/api/cpp/classpulsar_1_1_consumer_configuration.html
index ef8c598..b12c78f 100644
--- a/content/api/cpp/classpulsar_1_1_consumer_configuration.html
+++ b/content/api/cpp/classpulsar_1_1_consumer_configuration.html
@@ -158,6 +158,12 @@ ConsumerCryptoFailureAction </td><td class="memItemRight" valign="bottom"><
<tr class="memitem:a6baa4dbfe938c813385d263ef5dc1e04"><td class="memItemLeft" align="right" valign="top"><a class="anchor" id="a6baa4dbfe938c813385d263ef5dc1e04"></a>
<a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td><td class="memItemRight" valign="bottom"><b>setCryptoFailureAction</b> (ConsumerCryptoFailureAction action)</td></tr>
<tr class="separator:a6baa4dbfe938c813385d263ef5dc1e04"><td class="memSeparator" colspan="2"> </td></tr>
+<tr class="memitem:a2635a64878d8bf47a24f0be2a1d14201"><td class="memItemLeft" align="right" valign="top"><a class="anchor" id="a2635a64878d8bf47a24f0be2a1d14201"></a>
+bool </td><td class="memItemRight" valign="bottom"><b>isReadCompacted</b> () const </td></tr>
+<tr class="separator:a2635a64878d8bf47a24f0be2a1d14201"><td class="memSeparator" colspan="2"> </td></tr>
+<tr class="memitem:ae3f12b9f76982d8ea64f80adfb8af960"><td class="memItemLeft" align="right" valign="top"><a class="anchor" id="ae3f12b9f76982d8ea64f80adfb8af960"></a>
+void </td><td class="memItemRight" valign="bottom"><b>setReadCompacted</b> (bool compacted)</td></tr>
+<tr class="separator:ae3f12b9f76982d8ea64f80adfb8af960"><td class="memSeparator" colspan="2"> </td></tr>
</table><table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="friends"></a>
Friends</h2></td></tr>
diff --git a/content/api/cpp/classpulsar_1_1_reader_configuration-members.html b/content/api/cpp/classpulsar_1_1_reader_configuration-members.html
index 85c4a3b..dbacbfc 100644
--- a/content/api/cpp/classpulsar_1_1_reader_configuration-members.html
+++ b/content/api/cpp/classpulsar_1_1_reader_configuration-members.html
@@ -100,9 +100,11 @@ var searchBox = new SearchBox("searchBox", "search",false,'Search');
<tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>getReceiverQueueSize</b>() const (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
<tr bgcolor="#f0f0f0"><td class="entry"><b>getSubscriptionRolePrefix</b>() const (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
<tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>hasReaderListener</b>() const (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0"><td class="entry"><b>operator=</b>(const ReaderConfiguration &) (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>ReaderConfiguration</b>() (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
- <tr bgcolor="#f0f0f0"><td class="entry"><b>ReaderConfiguration</b>(const ReaderConfiguration &) (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>isReadCompacted</b>() const (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>operator=</b>(const ReaderConfiguration &) (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>ReaderConfiguration</b>() (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0" class="even"><td class="entry"><b>ReaderConfiguration</b>(const ReaderConfiguration &) (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
+ <tr bgcolor="#f0f0f0"><td class="entry"><b>setReadCompacted</b>(bool compacted) (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
<tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html#aa0d6dc39f30014d4d37872e9ddc85590">setReaderListener</a>(ReaderListener listener)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
<tr bgcolor="#f0f0f0"><td class="entry"><b>setReaderName</b>(const std::string &readerName) (defined in <a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a>)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
<tr class="even"><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html#a0574cedc0bc7ccf457071df866830abe">setReceiverQueueSize</a>(int size)</td><td class="entry"><a class="el" href="classpulsar_1_1_reader_configuration.html">pulsar::ReaderConfiguration</a></td><td class="entry"></td></tr>
diff --git a/content/api/cpp/classpulsar_1_1_reader_configuration.html b/content/api/cpp/classpulsar_1_1_reader_configuration.html
index 94de8e0..320c4cf 100644
--- a/content/api/cpp/classpulsar_1_1_reader_configuration.html
+++ b/content/api/cpp/classpulsar_1_1_reader_configuration.html
@@ -131,6 +131,12 @@ void </td><td class="memItemRight" valign="bottom"><b>setSubscriptionRolePr
<tr class="memitem:ae3f5aa93a66d946fc6a11a7a2ba7ba20"><td class="memItemLeft" align="right" valign="top"><a class="anchor" id="ae3f5aa93a66d946fc6a11a7a2ba7ba20"></a>
const std::string & </td><td class="memItemRight" valign="bottom"><b>getSubscriptionRolePrefix</b> () const </td></tr>
<tr class="separator:ae3f5aa93a66d946fc6a11a7a2ba7ba20"><td class="memSeparator" colspan="2"> </td></tr>
+<tr class="memitem:aaf766afd6e75d0e1454d81d980f019b3"><td class="memItemLeft" align="right" valign="top"><a class="anchor" id="aaf766afd6e75d0e1454d81d980f019b3"></a>
+void </td><td class="memItemRight" valign="bottom"><b>setReadCompacted</b> (bool compacted)</td></tr>
+<tr class="separator:aaf766afd6e75d0e1454d81d980f019b3"><td class="memSeparator" colspan="2"> </td></tr>
+<tr class="memitem:a8ad4f393183dd3f5c09df5772eb2f83c"><td class="memItemLeft" align="right" valign="top"><a class="anchor" id="a8ad4f393183dd3f5c09df5772eb2f83c"></a>
+bool </td><td class="memItemRight" valign="bottom"><b>isReadCompacted</b> () const </td></tr>
+<tr class="separator:a8ad4f393183dd3f5c09df5772eb2f83c"><td class="memSeparator" colspan="2"> </td></tr>
</table>
<a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2>
<div class="textblock"><p>Class specifying the configuration of a consumer. </p>
diff --git a/content/api/cpp/consumer__configuration_8h_source.html b/content/api/cpp/consumer__configuration_8h_source.html
index 077f48b..3c65832 100644
--- a/content/api/cpp/consumer__configuration_8h_source.html
+++ b/content/api/cpp/consumer__configuration_8h_source.html
@@ -89,7 +89,7 @@ var searchBox = new SearchBox("searchBox", "search",false,'Search');
<div class="title">consumer_configuration.h</div> </div>
</div><!--header-->
<div class="contents">
-<div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> </div><div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#pragma once</span></div><div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div><div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#ifdef __cplusplus</span></div><div class="line"><a name="l00022">< [...]
+<div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> </div><div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#pragma once</span></div><div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div><div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#ifdef __cplusplus</span></div><div class="line"><a name="l00022">< [...]
<!-- start footer part -->
<hr class="footer"/><address class="footer"><small>
Generated by  <a href="http://www.doxygen.org/index.html">
diff --git a/content/api/cpp/reader__configuration_8h_source.html b/content/api/cpp/reader__configuration_8h_source.html
index 29cb6e9..39900dc 100644
--- a/content/api/cpp/reader__configuration_8h_source.html
+++ b/content/api/cpp/reader__configuration_8h_source.html
@@ -89,7 +89,7 @@ var searchBox = new SearchBox("searchBox", "search",false,'Search');
<div class="title">reader_configuration.h</div> </div>
</div><!--header-->
<div class="contents">
-<div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> </div><div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#pragma once</span></div><div class="line"><a name="l00021"></a><span class="lineno"> 21</span> </div><div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#ifdef __cplusplus</span></div><div class="line"><a name="l00023">< [...]
+<div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> </div><div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#pragma once</span></div><div class="line"><a name="l00021"></a><span class="lineno"> 21</span> </div><div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#ifdef __cplusplus</span></div><div class="line"><a name="l00023">< [...]
<!-- start footer part -->
<hr class="footer"/><address class="footer"><small>
Generated by  <a href="http://www.doxygen.org/index.html">
diff --git a/content/api/python/index.html b/content/api/python/index.html
index 69faa9d..8b9f65c 100644
--- a/content/api/python/index.html
+++ b/content/api/python/index.html
@@ -1510,7 +1510,8 @@ class Client:
receiver_queue_size=1000,
consumer_name=None,
unacked_messages_timeout_ms=None,
- broker_consumer_stats_cache_time_ms=30000
+ broker_consumer_stats_cache_time_ms=30000,
+ is_read_compacted=False
):
"""
Subscribe to the given topic and subscription combination.
@@ -1568,9 +1569,11 @@ class Client:
_check_type_or_none(str, consumer_name, 'consumer_name')
_check_type_or_none(int, unacked_messages_timeout_ms, 'unacked_messages_timeout_ms')
_check_type(int, broker_consumer_stats_cache_time_ms, 'broker_consumer_stats_cache_time_ms')
+ _check_type(bool, is_read_compacted, 'is_read_compacted')
conf = _pulsar.ConsumerConfiguration()
conf.consumer_type(consumer_type)
+ conf.read_compacted(is_read_compacted)
if message_listener:
conf.message_listener(message_listener)
conf.receiver_queue_size(receiver_queue_size)
@@ -2246,7 +2249,8 @@ producers and consumers.</p></div>
receiver_queue_size=1000,
consumer_name=None,
unacked_messages_timeout_ms=None,
- broker_consumer_stats_cache_time_ms=30000
+ broker_consumer_stats_cache_time_ms=30000,
+ is_read_compacted=False
):
"""
Subscribe to the given topic and subscription combination.
@@ -2304,9 +2308,11 @@ producers and consumers.</p></div>
_check_type_or_none(str, consumer_name, 'consumer_name')
_check_type_or_none(int, unacked_messages_timeout_ms, 'unacked_messages_timeout_ms')
_check_type(int, broker_consumer_stats_cache_time_ms, 'broker_consumer_stats_cache_time_ms')
+ _check_type(bool, is_read_compacted, 'is_read_compacted')
conf = _pulsar.ConsumerConfiguration()
conf.consumer_type(consumer_type)
+ conf.read_compacted(is_read_compacted)
if message_listener:
conf.message_listener(message_listener)
conf.receiver_queue_size(receiver_queue_size)
@@ -2803,7 +2809,7 @@ producers and consumers.</p></div>
<div class="item">
<div class="name def" id="pulsar.Client.subscribe">
- <p>def <span class="ident">subscribe</span>(</p><p>self, topic, subscription_name, consumer_type=_pulsar.ConsumerType.Exclusive, message_listener=None, receiver_queue_size=1000, consumer_name=None, unacked_messages_timeout_ms=None, broker_consumer_stats_cache_time_ms=30000)</p>
+ <p>def <span class="ident">subscribe</span>(</p><p>self, topic, subscription_name, consumer_type=_pulsar.ConsumerType.Exclusive, message_listener=None, receiver_queue_size=1000, consumer_name=None, unacked_messages_timeout_ms=None, broker_consumer_stats_cache_time_ms=30000, is_read_compacted=False)</p>
</div>
@@ -2868,7 +2874,8 @@ def my_listener(consumer, message):
receiver_queue_size=1000,
consumer_name=None,
unacked_messages_timeout_ms=None,
- broker_consumer_stats_cache_time_ms=30000
+ broker_consumer_stats_cache_time_ms=30000,
+ is_read_compacted=False
):
"""
Subscribe to the given topic and subscription combination.
@@ -2920,8 +2927,10 @@ def my_listener(consumer, message):
_check_type_or_none(str, consumer_name, 'consumer_name')
_check_type_or_none(int, unacked_messages_timeout_ms, 'unacked_messages_timeout_ms')
_check_type(int, broker_consumer_stats_cache_time_ms, 'broker_consumer_stats_cache_time_ms')
+ _check_type(bool, is_read_compacted, 'is_read_compacted')
conf = _pulsar.ConsumerConfiguration()
conf.consumer_type(consumer_type)
+ conf.read_compacted(is_read_compacted)
if message_listener:
conf.message_listener(message_listener)
conf.receiver_queue_size(receiver_queue_size)
diff --git a/content/docs/latest/cookbooks/compaction/index.html b/content/docs/latest/cookbooks/compaction/index.html
index 68d4337..2f94ec7 100644
--- a/content/docs/latest/cookbooks/compaction/index.html
+++ b/content/docs/latest/cookbooks/compaction/index.html
@@ -1568,7 +1568,7 @@
<ul>
<li>You need to give messages keys, as topic compaction in Pulsar takes place on a <em>per-key basis</em> (i.e. messages are compacted based on their key). For a stock ticker use case, the stock symbol—e.g. <code class="highlighter-rouge">AAPL</code> or <code class="highlighter-rouge">GOOG</code>—could serve as the key (more on this <a href="#when">below</a>). Messages without keys will be left alone by the compaction process.</li>
- <li>You must manually <a href="#trigger">trigger</a> compaction using the Pulsar administrative API. This will both run a compaction operation <em>and</em> mark the topic as a compacted topic.</li>
+ <li>Compaction can be configured to run <a href="#automatic">automatically</a>, or you can manually <a href="#trigger">trigger</a> compaction using the Pulsar administrative API.</li>
<li>Your <span class="popover-term" tabindex="0" title="What is a consumer?" data-placement="top" data-content="A process that establishes a subscription to a Pulsar topic and processes messages published to that topic by producers." data-toggle="popover" data-trigger="focus">consumers</span> must be <a href="#config">configured</a> to read from compacted topics (<a href="#java">Java consumers</a>, for example, have a <code class="highlighter-rouge">readCompacted</code> setting that mu [...]
</ul>
@@ -1632,7 +1632,19 @@
</div>
</div>
-<h2 id="trigger">Triggering compaction</h2>
+<h2 id="automatic">Configuring compaction to run automatically</h2>
+
+<p>Tenant administrators can configure a policy for compaction at the namespace level. The policy specifies how large the topic backlog can grow before compaction is triggered.</p>
+
+<p>For example, to trigger compaction when the backlog reaches 100MB:</p>
+
+<div class="language-bash highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nv">$ </span>bin/pulsar-admin namespaces set-compaction-threshold <span class="se">\</span>
+ <span class="nt">--threshold</span> 100M my-tenant/my-namespace
+</code></pre></div></div>
+
+<p>Configuring the compaction threshold on a namespace will apply to all topics within that namespace.</p>
+
+<h2 id="trigger">Triggering compaction manually</h2>
<p>In order to run compaction on a topic, you need to use the <a href="../../CliTools#pulsar-admin-topics-compact"><code class="highlighter-rouge">topics compact</code></a> command for the <a href="../../CliTools#pulsar-admin"><code class="highlighter-rouge">pulsar-admin</code></a> CLI tool. Here’s an example:</p>
@@ -1661,35 +1673,6 @@
<p>How often you <a href="#trigger">trigger compaction</a> will vary widely based on the use case. If you want a compacted topic to be extremely speedy on read, then you should run compaction fairly frequently.</p>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one
- or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information
- regarding copyright ownership. The ASF licenses this file
- to you under the Apache License, Version 2.0 (the
- "License"); you may not use this file except in compliance
- with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing,
- software distributed under the License is distributed on an
- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- KIND, either express or implied. See the License for the
- specific language governing permissions and limitations
- under the License.
-
--->
-<div class="admonition">
- <div class="warning">
- <span class="admonition-title"><p>No automatic compaction</p>
-</span>
- <p>Currently, all topic compaction in Pulsar must be initiated manually via the <a href="#trigger">CLI</a> or <a href="../../reference/RestApi">REST API</a>.</p>
-
- </div>
-</div>
-
<h2 id="config">Consumer configuration</h2>
<p>Pulsar consumers and readers need to be configured to read from compacted topics. The sections below show you how to enable compacted topic reads for Pulsar’s language clients. If the</p>
diff --git a/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html b/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html
index 6f072cc..2a2b7f7 100644
--- a/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html
+++ b/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html
@@ -2989,7 +2989,7 @@
<ul>
<li>Allos for much more efficient “rewind” through topic logs</li>
<li>Applies only to <a href="#persistent-storage">persistent topics</a></li>
- <li>Is triggered manually via the command line. See the <a href="../../cookbooks/compaction">Topic compaction cookbook</a></li>
+ <li>Triggered automatically when the backlog reaches a certain size or can be triggered manually via the command line. See the <a href="../../cookbooks/compaction">Topic compaction cookbook</a></li>
<li>Is conceptually and operationally distinct from <a href="#message-retention-and-expiry">retention and expiry</a>. Topic compaction <em>does</em>, however, respect retention. If retention has removed a message from the message backlog of a topic, the message will also not be readable from the compacted topic ledger.</li>
</ul>
diff --git a/content/docs/latest/project/BinaryProtocol/index.html b/content/docs/latest/project/BinaryProtocol/index.html
index 05cfb09..c8bcba7 100644
--- a/content/docs/latest/project/BinaryProtocol/index.html
+++ b/content/docs/latest/project/BinaryProtocol/index.html
@@ -6238,6 +6238,20 @@ incrementally added to the protocol</p>
<td>
</td>
</tr>
+
+ <tr>
+ <td>Protobuf</td>
+ <td>3</td>
+ <td>
+</td>
+ </tr>
+
+ <tr>
+ <td>Avro</td>
+ <td>4</td>
+ <td>
+</td>
+ </tr>
<!-- for value in values -->
</tbody>
</table>
diff --git a/content/docs/latest/reference/CliTools/index.html b/content/docs/latest/reference/CliTools/index.html
index 5f21742..a611d27 100644
--- a/content/docs/latest/reference/CliTools/index.html
+++ b/content/docs/latest/reference/CliTools/index.html
@@ -5939,6 +5939,18 @@
<code class="highlighter-rouge">unsubscribe</code>
</a>
</li>
+
+ <li>
+ <a href="#pulsar-admin-namespaces-get-compaction-threshold">
+ <code class="highlighter-rouge">get-compaction-threshold</code>
+ </a>
+ </li>
+
+ <li>
+ <a href="#pulsar-admin-namespaces-set-compaction-threshold">
+ <code class="highlighter-rouge">set-compaction-threshold</code>
+ </a>
+ </li>
<!-- for subcommand in subcommands -->
</ul>
@@ -6780,6 +6792,61 @@
<!-- if command.example -->
</div>
</div>
+
+ <div class="card cli-subcommand">
+ <h4 class="card-header-title" id="pulsar-admin-namespaces-get-compaction-threshold"><code class="highlighter-rouge">get-compaction-threshold</code></h4>
+ <div class="card-content">
+ <p>Get compactionThreshold for a namespace</p>
+ <h5>Usage</h5>
+ <div class="language-shell highlighter-rouge"><pre class="highlight"><code><span class="gp">$</span> pulsar-admin namespaces get-compaction-threshold <span class="command">tenant/namespace</span></code></pre></div>
+ <!-- if subcommand.options -->
+ <!-- if command.example -->
+ </div>
+ </div>
+
+ <div class="card cli-subcommand">
+ <h4 class="card-header-title" id="pulsar-admin-namespaces-set-compaction-threshold"><code class="highlighter-rouge">set-compaction-threshold</code></h4>
+ <div class="card-content">
+ <p>Set compactionThreshold for a namespace</p>
+ <h5>Usage</h5>
+ <div class="language-shell highlighter-rouge"><pre class="highlight"><code><span class="gp">$</span> pulsar-admin namespaces set-compaction-threshold <span class="command">tenant/namespace</span> <span class="options">options</span></code></pre></div>
+
+ <h5>Options</h5>
+ <table class="options-table">
+ <thead>
+ <tr>
+ <th>Flag</th>
+ <th>Description</th>
+ <th>Default</th>
+ </tr>
+ <tbody>
+
+ <tr>
+ <td nowrap="">
+
+
+ <code class="highlighter-rouge">-t</code>
+ ,
+
+ <code class="highlighter-rouge">--threshold</code>
+
+ <!-- for flag in option.flags -->
+ </td>
+ <td><p>Maximum number of bytes in a topic backlog before compaction is triggered (eg: 10M, 16G, 3T). 0 disables automatic compaction</p>
+</td>
+ <td>
+ <p>0</p>
+
+ </td>
+ </tr>
+ <!-- for option in options -->
+ </tbody>
+ </thead>
+ </table>
+ <!-- if subcommand.options -->
+ <!-- if command.example -->
+ </div>
+ </div>
<!-- for subcommand in subcommands -->
</div>
diff --git a/content/ja/project/BinaryProtocol/index.html b/content/ja/project/BinaryProtocol/index.html
index 9b547be..2b39c91 100644
--- a/content/ja/project/BinaryProtocol/index.html
+++ b/content/ja/project/BinaryProtocol/index.html
@@ -5911,6 +5911,20 @@ incrementally added to the protocol</p>
<td>
</td>
</tr>
+
+ <tr>
+ <td>Protobuf</td>
+ <td>3</td>
+ <td>
+</td>
+ </tr>
+
+ <tr>
+ <td>Avro</td>
+ <td>4</td>
+ <td>
+</td>
+ </tr>
<!-- for value in values -->
</tbody>
</table>
diff --git a/content/ja/reference/CliTools/index.html b/content/ja/reference/CliTools/index.html
index 81e6094..d57e48a 100644
--- a/content/ja/reference/CliTools/index.html
+++ b/content/ja/reference/CliTools/index.html
@@ -5715,6 +5715,18 @@
<code class="highlighter-rouge">unsubscribe</code>
</a>
</li>
+
+ <li>
+ <a href="#pulsar-admin-namespaces-get-compaction-threshold">
+ <code class="highlighter-rouge">get-compaction-threshold</code>
+ </a>
+ </li>
+
+ <li>
+ <a href="#pulsar-admin-namespaces-set-compaction-threshold">
+ <code class="highlighter-rouge">set-compaction-threshold</code>
+ </a>
+ </li>
<!-- for subcommand in subcommands -->
</ul>
@@ -6556,6 +6568,61 @@
<!-- if command.example -->
</div>
</div>
+
+ <div class="card cli-subcommand">
+ <h4 class="card-header-title" id="pulsar-admin-namespaces-get-compaction-threshold"><code class="highlighter-rouge">get-compaction-threshold</code></h4>
+ <div class="card-content">
+ <p>Get compactionThreshold for a namespace</p>
+ <h5>Usage</h5>
+ <div class="language-shell highlighter-rouge"><pre class="highlight"><code><span class="gp">$</span> pulsar-admin namespaces get-compaction-threshold <span class="command">tenant/namespace</span></code></pre></div>
+ <!-- if subcommand.options -->
+ <!-- if command.example -->
+ </div>
+ </div>
+
+ <div class="card cli-subcommand">
+ <h4 class="card-header-title" id="pulsar-admin-namespaces-set-compaction-threshold"><code class="highlighter-rouge">set-compaction-threshold</code></h4>
+ <div class="card-content">
+ <p>Set compactionThreshold for a namespace</p>
+ <h5>Usage</h5>
+ <div class="language-shell highlighter-rouge"><pre class="highlight"><code><span class="gp">$</span> pulsar-admin namespaces set-compaction-threshold <span class="command">tenant/namespace</span> <span class="options">options</span></code></pre></div>
+
+ <h5>Options</h5>
+ <table class="options-table">
+ <thead>
+ <tr>
+ <th>Flag</th>
+ <th>Description</th>
+ <th>Default</th>
+ </tr>
+ <tbody>
+
+ <tr>
+ <td nowrap="">
+
+
+ <code class="highlighter-rouge">-t</code>
+ ,
+
+ <code class="highlighter-rouge">--threshold</code>
+
+ <!-- for flag in option.flags -->
+ </td>
+ <td><p>Maximum number of bytes in a topic backlog before compaction is triggered (eg: 10M, 16G, 3T). 0 disables automatic compaction</p>
+</td>
+ <td>
+ <p>0</p>
+
+ </td>
+ </tr>
+ <!-- for option in options -->
+ </tbody>
+ </thead>
+ </table>
+ <!-- if subcommand.options -->
+ <!-- if command.example -->
+ </div>
+ </div>
<!-- for subcommand in subcommands -->
</div>
--
To stop receiving notification emails like this one, please contact
mmerli@apache.org.