Deploy website

Deploy website version based on b3338aa

api/fs2/kafka/ConsumerSettings.html

@@ -15,7 +15,7 @@
 records are being processed, there can be up to <code>maxPrefetchBatches * max.poll.records</code>
 records per topic-partition that have already been fetched, and are waiting to be processed.
 You can use <a href="#withMaxPollRecords(maxPollRecords:Int):fs2.kafka.ConsumerSettings[F,K,V]" name="fs2.kafka.ConsumerSettings#withMaxPollRecords" id="fs2.kafka.ConsumerSettings#withMaxPollRecords" class="extmbr">withMaxPollRecords</a> to control the <code>max.poll.records</code> setting.<br><br></p><p>This setting effectively controls backpressure, i.e. the maximum number of batches to prefetch
-per topic-parititon before starting to slow down (not fetching more records) until processing
+per topic-partition before starting to slow down (not fetching more records) until processing
 has caught-up.<br><br></p><p>Note that prefetching cannot be disabled and is generally preferred since it yields improved
 performance. The minimum value for this setting is <code>2</code>.
 </p></div></div></li><li class="indented0 " name="fs2.kafka.ConsumerSettings#pollInterval" group="Ungrouped" fullComment="yes" data-isabs="true" visbl="pub"><a id="pollInterval:scala.concurrent.duration.FiniteDuration" class="anchorToMember"></a><a id="pollInterval:FiniteDuration" class="anchorToMember"></a> <span class="permalink"><a href="../../fs2/kafka/ConsumerSettings.html#pollInterval:scala.concurrent.duration.FiniteDuration" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">abstract </span> <span class="kind">def</span></span> <span class="symbol"><span class="name">pollInterval</span><span class="result">: <a href="https://www.scala-lang.org/api/2.13.12/scala/concurrent/duration/FiniteDuration.html#scala.concurrent.duration.FiniteDuration" name="scala.concurrent.duration.FiniteDuration" id="scala.concurrent.duration.FiniteDuration" class="extype">FiniteDuration</a></span></span><p class="shortcomment cmt">How often we should attempt to call <code>poll</code> on the Java <code>KafkaConsumer</code>.<br><br></p><div class="fullcomment"><div class="comment cmt"><p>How often we should attempt to call <code>poll</code> on the Java <code>KafkaConsumer</code>.<br><br></p><p>The default value is 50 milliseconds.

api/fs2/kafka/KafkaConsumer.html

@@ -26,7 +26,7 @@
 one).<br><br></p><p>Manual topic assignment through this method does not use the consumer's group management
 functionality. As such, there will be no rebalance operation triggered when group membership
 or cluster and topic metadata change. Note that it is not possible to use both manual
-partition assignment with <code>assign</code> and group assigment with <code>subscribe</code>.<br><br></p><p>If auto-commit is enabled, an async commit (based on the old assignment) will be triggered
+partition assignment with <code>assign</code> and group assignment with <code>subscribe</code>.<br><br></p><p>If auto-commit is enabled, an async commit (based on the old assignment) will be triggered
 before the new assignment replaces the old one.<br><br></p><p>To unassign all partitions, use <a href="#unsubscribe:F[Unit]" name="fs2.kafka.KafkaConsumer#unsubscribe" id="fs2.kafka.KafkaConsumer#unsubscribe" class="extmbr">KafkaConsumer#unsubscribe</a>.
 </p></div><dl class="attributes block"><dt>Definition Classes</dt><dd><a href="consumer/KafkaAssignment.html" name="fs2.kafka.consumer.KafkaAssignment" id="fs2.kafka.consumer.KafkaAssignment" class="extype">KafkaAssignment</a></dd><dt>See also</dt><dd><span class="cmt"><p>
   org.apache.kafka.clients.consumer.KafkaConsumer#assign</p></span></dd></dl></div></li><li class="indented0 " name="fs2.kafka.consumer.KafkaAssignment#assignment" group="Ungrouped" fullComment="yes" data-isabs="true" visbl="pub"><a id="assignment:F[scala.collection.immutable.SortedSet[org.apache.kafka.common.TopicPartition]]" class="anchorToMember"></a><a id="assignment:F[SortedSet[TopicPartition]]" class="anchorToMember"></a> <span class="permalink"><a href="../../fs2/kafka/KafkaConsumer.html#assignment:F[scala.collection.immutable.SortedSet[org.apache.kafka.common.TopicPartition]]" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">abstract </span> <span class="kind">def</span></span> <span class="symbol"><span class="name">assignment</span><span class="result">: <span name="fs2.kafka.KafkaConsumer.F" class="extype">F</span>[<a href="https://www.scala-lang.org/api/2.13.12/scala/collection/immutable/SortedSet.html#scala.collection.immutable.SortedSet" name="scala.collection.immutable.SortedSet" id="scala.collection.immutable.SortedSet" class="extype">SortedSet</a>[<span name="org.apache.kafka.common.TopicPartition" class="extype">TopicPartition</span>]]</span></span><p class="shortcomment cmt">Returns the set of partitions currently assigned to this consumer.</p><div class="fullcomment"><div class="comment cmt"><p>Returns the set of partitions currently assigned to this consumer.

api/fs2/kafka/consumer/KafkaAssignment.html

@@ -4,7 +4,7 @@
 one).<br><br></p><p>Manual topic assignment through this method does not use the consumer's group management
 functionality. As such, there will be no rebalance operation triggered when group membership
 or cluster and topic metadata change. Note that it is not possible to use both manual
-partition assignment with <code>assign</code> and group assigment with <code>subscribe</code>.<br><br></p><p>If auto-commit is enabled, an async commit (based on the old assignment) will be triggered
+partition assignment with <code>assign</code> and group assignment with <code>subscribe</code>.<br><br></p><p>If auto-commit is enabled, an async commit (based on the old assignment) will be triggered
 before the new assignment replaces the old one.<br><br></p><p>To unassign all partitions, use <a href="../KafkaConsumer.html#unsubscribe:F[Unit]" name="fs2.kafka.KafkaConsumer#unsubscribe" id="fs2.kafka.KafkaConsumer#unsubscribe" class="extmbr">KafkaConsumer#unsubscribe</a>.
 </p></div><dl class="attributes block"><dt>See also</dt><dd><span class="cmt"><p>
   org.apache.kafka.clients.consumer.KafkaConsumer#assign</p></span></dd></dl></div></li><li class="indented0 " name="fs2.kafka.consumer.KafkaAssignment#assignment" group="Ungrouped" fullComment="no" data-isabs="true" visbl="pub"><a id="assignment:F[scala.collection.immutable.SortedSet[org.apache.kafka.common.TopicPartition]]" class="anchorToMember"></a><a id="assignment:F[SortedSet[TopicPartition]]" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html#assignment:F[scala.collection.immutable.SortedSet[org.apache.kafka.common.TopicPartition]]" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">abstract </span> <span class="kind">def</span></span> <span class="symbol"><span class="name">assignment</span><span class="result">: <span name="fs2.kafka.consumer.KafkaAssignment.F" class="extype">F</span>[<a href="https://www.scala-lang.org/api/2.13.12/scala/collection/immutable/SortedSet.html#scala.collection.immutable.SortedSet" name="scala.collection.immutable.SortedSet" id="scala.collection.immutable.SortedSet" class="extype">SortedSet</a>[<span name="org.apache.kafka.common.TopicPartition" class="extype">TopicPartition</span>]]</span></span><p class="shortcomment cmt">Returns the set of partitions currently assigned to this consumer.</p></li><li class="indented0 " name="fs2.kafka.consumer.KafkaAssignment#assignmentStream" group="Ungrouped" fullComment="yes" data-isabs="true" visbl="pub"><a id="assignmentStream:fs2.Stream[F,scala.collection.immutable.SortedSet[org.apache.kafka.common.TopicPartition]]" class="anchorToMember"></a><a id="assignmentStream:Stream[F,SortedSet[TopicPartition]]" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html#assignmentStream:fs2.Stream[F,scala.collection.immutable.SortedSet[org.apache.kafka.common.TopicPartition]]" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">abstract </span> <span class="kind">def</span></span> <span class="symbol"><span class="name">assignmentStream</span><span class="result">: <a href="https://www.javadoc.io/doc/co.fs2/fs2-docs_2.13/3.9.2/fs2/Stream.html#fs2.Stream" name="fs2.Stream" id="fs2.Stream" class="extype">Stream</a>[<span name="fs2.kafka.consumer.KafkaAssignment.F" class="extype">F</span>, <a href="https://www.scala-lang.org/api/2.13.12/scala/collection/immutable/SortedSet.html#scala.collection.immutable.SortedSet" name="scala.collection.immutable.SortedSet" id="scala.collection.immutable.SortedSet" class="extype">SortedSet</a>[<span name="org.apache.kafka.common.TopicPartition" class="extype">TopicPartition</span>]]</span></span><p class="shortcomment cmt"><code>Stream</code> where the elements are the set of <code>TopicPartition</code>s currently assigned to this

docs/overview.html

@@ -84,7 +84,7 @@ <h3><a class="anchor" aria-hidden="true" id="snapshot-releases"></a><a href="#sn
 <p>To use the latest snapshot release, add the following lines to your <code>build.sbt</code> file.</p>
 <pre><code class="hljs css language-scala">resolvers += <span class="hljs-type">Resolver</span>.sonatypeRepo(<span class="hljs-string">"snapshots"</span>)
 
-libraryDependencies += <span class="hljs-string">"com.github.fd4s"</span> %% <span class="hljs-string">"fs2-kafka"</span> % <span class="hljs-string">"3.2.0-2-15d32d9-SNAPSHOT"</span>
+libraryDependencies += <span class="hljs-string">"com.github.fd4s"</span> %% <span class="hljs-string">"fs2-kafka"</span> % <span class="hljs-string">"3.2.0-3-b3338aa-SNAPSHOT"</span>
 </code></pre>
 <h2><a class="anchor" aria-hidden="true" id="dependencies"></a><a href="#dependencies" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1-2.09V6.25c-1.09.53-2 1.84-2 3.25C6 11.31 7.55 13 9 13h4c1.45 0 3-1.69 3-3.5S14.5 6 13 6z"></path></svg></a>Dependencies</h2>
 <p>Refer to the table below for dependencies and version support across modules.</p>

docs/overview/index.html

@@ -84,7 +84,7 @@ <h3><a class="anchor" aria-hidden="true" id="snapshot-releases"></a><a href="#sn
 <p>To use the latest snapshot release, add the following lines to your <code>build.sbt</code> file.</p>
 <pre><code class="hljs css language-scala">resolvers += <span class="hljs-type">Resolver</span>.sonatypeRepo(<span class="hljs-string">"snapshots"</span>)
 
-libraryDependencies += <span class="hljs-string">"com.github.fd4s"</span> %% <span class="hljs-string">"fs2-kafka"</span> % <span class="hljs-string">"3.2.0-2-15d32d9-SNAPSHOT"</span>
+libraryDependencies += <span class="hljs-string">"com.github.fd4s"</span> %% <span class="hljs-string">"fs2-kafka"</span> % <span class="hljs-string">"3.2.0-3-b3338aa-SNAPSHOT"</span>
 </code></pre>
 <h2><a class="anchor" aria-hidden="true" id="dependencies"></a><a href="#dependencies" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1-2.09V6.25c-1.09.53-2 1.84-2 3.25C6 11.31 7.55 13 9 13h4c1.45 0 3-1.69 3-3.5S14.5 6 13 6z"></path></svg></a>Dependencies</h2>
 <p>Refer to the table below for dependencies and version support across modules.</p>