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 <bui...@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 mme...@apache.org.