deploy: e49213a

Author: nick-zh

consumer/index.xml

@@ -24,7 +24,7 @@ The returned offset for each partition is the earliest offset whose
 timestamp is greater than or equal to the given timestamp in the
 corresponding partition.
 Example $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $topicPartition = new TopicPartition(&amp;#39;test-topic&amp;#39;, 0, strtotime(&amp;#34;-1 week&amp;#34;)); $offsetsOneWeekAgo = $consumer-&amp;gt;offsetForTimes([$topicPartition], 10000);</description></item><item><title>queryWatermarkOffsets</title><link>https://php-kafka.github.io/consumer/queryWatermarkOffsets/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/consumer/queryWatermarkOffsets/</guid><description>Description public function queryWatermarkOffsets(string $topic, int $partition, int &amp;amp;$low, int &amp;amp;$high, int $timeoutMs): void {} Query broker for low (oldest) and high (newest) offsets for a partition
-Example $low = 0; $high = 0; $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $topicPartition = new TopicPartition(&amp;#39;test-topic&amp;#39;, 0, strtotime(&amp;#34;-1 week&amp;#34;)); $consumer-&amp;gt;queryWatermarkOffsets(&amp;#39;test-topic, 0, int &amp;amp;$low, int &amp;amp;$high, 10000);</description></item><item><title>subscribe</title><link>https://php-kafka.github.io/consumer/subscribe/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/consumer/subscribe/</guid><description>Description public function subscribe(array $topics): void {} Subscribe to one or more topics (regexp also supported).
+Example $low = 0; $high = 0; $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $topicPartition = new TopicPartition(&amp;#39;test-topic&amp;#39;, 0, strtotime(&amp;#34;-1 week&amp;#34;)); $consumer-&amp;gt;queryWatermarkOffsets(&amp;#39;test-topic&amp;#39;, 0, int &amp;amp;$low, int &amp;amp;$high, 10000);</description></item><item><title>subscribe</title><link>https://php-kafka.github.io/consumer/subscribe/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/consumer/subscribe/</guid><description>Description public function subscribe(array $topics): void {} Subscribe to one or more topics (regexp also supported).
 Any previous subscription will be unassigned and unsubscribed first.
 Example $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $consumer-&amp;gt;subscribe([&amp;#39;test-topic&amp;#39;]);</description></item><item><title>unsubscribe</title><link>https://php-kafka.github.io/consumer/unsubscribe/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/consumer/unsubscribe/</guid><description>Description public function unsubscribe(): void {} Unsubscribe from the current subscriptions
 Example $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $consumer-&amp;gt;subscribe([&amp;#39;test-topic&amp;#39;]); $consumer-&amp;gt;unsubscribe();</description></item></channel></rss>

consumer/queryWatermarkOffsets/index.html

@@ -8,5 +8,5 @@
 <span class=nv>$conf</span><span class=o>-&gt;</span><span class=na>set</span><span class=p>(</span><span class=s1>&#39;metadata.broker.list&#39;</span><span class=p>,</span> <span class=s1>&#39;kafka:9092&#39;</span><span class=p>);</span>
 <span class=nv>$consumer</span> <span class=o>=</span> <span class=k>new</span> <span class=nx>Kafka\Consumer</span><span class=p>(</span><span class=nv>$conf</span><span class=p>);</span>
 <span class=nv>$topicPartition</span> <span class=o>=</span> <span class=k>new</span> <span class=nx>TopicPartition</span><span class=p>(</span><span class=s1>&#39;test-topic&#39;</span><span class=p>,</span> <span class=mi>0</span><span class=p>,</span> <span class=nx>strtotime</span><span class=p>(</span><span class=s2>&#34;-1 week&#34;</span><span class=p>));</span>
-<span class=nv>$consumer</span><span class=o>-&gt;</span><span class=na>queryWatermarkOffsets</span><span class=p>(</span><span class=err>&#39;</span><span class=nx>test</span><span class=o>-</span><span class=nx>topic</span><span class=p>,</span> <span class=mi>0</span><span class=p>,</span> <span class=nx>int</span> <span class=o>&amp;</span><span class=nv>$low</span><span class=p>,</span> <span class=nx>int</span> <span class=o>&amp;</span><span class=nv>$high</span><span class=p>,</span> <span class=mi>10000</span><span class=p>);</span>
+<span class=nv>$consumer</span><span class=o>-&gt;</span><span class=na>queryWatermarkOffsets</span><span class=p>(</span><span class=s1>&#39;test-topic&#39;</span><span class=p>,</span> <span class=mi>0</span><span class=p>,</span> <span class=nx>int</span> <span class=o>&amp;</span><span class=nv>$low</span><span class=p>,</span> <span class=nx>int</span> <span class=o>&amp;</span><span class=nv>$high</span><span class=p>,</span> <span class=mi>10000</span><span class=p>);</span>
 </code></pre></div></article><div class="gdoc-page__footer flex flex-wrap justify-between"></div></div></main><footer class=gdoc-footer><div class="container flex flex-wrap"><span class=gdoc-footer__item>Built with <a href=https://gohugo.io/ class=gdoc-footer__link>Hugo</a> and<svg class="icon heart"><use xlink:href="#heart"/></svg></span></div></footer></div><script defer src=/js/clipboard-af8ab36589.min.js></script><script>document.addEventListener("DOMContentLoaded",function(event){var clipboard=new ClipboardJS('.clip');});</script></body></html>

index.xml

@@ -28,7 +28,7 @@ The returned offset for each partition is the earliest offset whose
 timestamp is greater than or equal to the given timestamp in the
 corresponding partition.
 Example $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $topicPartition = new TopicPartition(&amp;#39;test-topic&amp;#39;, 0, strtotime(&amp;#34;-1 week&amp;#34;)); $offsetsOneWeekAgo = $consumer-&amp;gt;offsetForTimes([$topicPartition], 10000);</description></item><item><title>queryWatermarkOffsets</title><link>https://php-kafka.github.io/consumer/queryWatermarkOffsets/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/consumer/queryWatermarkOffsets/</guid><description>Description public function queryWatermarkOffsets(string $topic, int $partition, int &amp;amp;$low, int &amp;amp;$high, int $timeoutMs): void {} Query broker for low (oldest) and high (newest) offsets for a partition
-Example $low = 0; $high = 0; $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $topicPartition = new TopicPartition(&amp;#39;test-topic&amp;#39;, 0, strtotime(&amp;#34;-1 week&amp;#34;)); $consumer-&amp;gt;queryWatermarkOffsets(&amp;#39;test-topic, 0, int &amp;amp;$low, int &amp;amp;$high, 10000);</description></item><item><title>Release v1.0.0</title><link>https://php-kafka.github.io/whats-new/release-1.0.0/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/whats-new/release-1.0.0/</guid><description>Initial release</description></item><item><title>set</title><link>https://php-kafka.github.io/configuration/set/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/configuration/set/</guid><description>Description public function set(string $name, string $value): void {} Set a configuration value
+Example $low = 0; $high = 0; $conf = Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;metadata.broker.list&amp;#39;, &amp;#39;kafka:9092&amp;#39;); $consumer = new Kafka\Consumer($conf); $topicPartition = new TopicPartition(&amp;#39;test-topic&amp;#39;, 0, strtotime(&amp;#34;-1 week&amp;#34;)); $consumer-&amp;gt;queryWatermarkOffsets(&amp;#39;test-topic&amp;#39;, 0, int &amp;amp;$low, int &amp;amp;$high, 10000);</description></item><item><title>Release v1.0.0</title><link>https://php-kafka.github.io/whats-new/release-1.0.0/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/whats-new/release-1.0.0/</guid><description>Initial release</description></item><item><title>set</title><link>https://php-kafka.github.io/configuration/set/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/configuration/set/</guid><description>Description public function set(string $name, string $value): void {} Set a configuration value
 Example $conf = new Kafka\Configuration(); $conf-&amp;gt;set(&amp;#39;auto.offset.reset&amp;#39;, &amp;#39;earliest&amp;#39;);</description></item><item><title>setDrMsgCb</title><link>https://php-kafka.github.io/configuration/setDrMsgCb/</link><pubDate>Sun, 27 Dec 2020 22:09:37 +0100</pubDate><guid>https://php-kafka.github.io/configuration/setDrMsgCb/</guid><description>Description public function setDrMsgCb(callable $callback): void {} Set a message delivery report callback
 This callback is called exactly once per message, indicating if
 the message was succesfully delivered or permanently failed delivery