Deploy website

Deploy website version based on a52870d

api/fs2/kafka/TransactionalKafkaProducer$.html

@@ -5,7 +5,7 @@
 <a href="TransactionalProducerSettings.html" name="fs2.kafka.TransactionalProducerSettings" id="fs2.kafka.TransactionalProducerSettings" class="extype">TransactionalProducerSettings</a>.</p><div class="fullcomment"><div class="comment cmt"><p>Creates a new <a href="TransactionalKafkaProducer.html" name="fs2.kafka.TransactionalKafkaProducer" id="fs2.kafka.TransactionalKafkaProducer" class="extype">TransactionalKafkaProducer</a> in the <code>Resource</code> context, using the specified
 <a href="TransactionalProducerSettings.html" name="fs2.kafka.TransactionalProducerSettings" id="fs2.kafka.TransactionalProducerSettings" class="extype">TransactionalProducerSettings</a>. Note that there is another version where <code>F[_]</code> is
 specified explicitly and the key and value type can be inferred, which allows you to use the
-following syntax.</p><pre>TransactionalKafkaProducer.resource[F].using(settings)</pre></div></div></li><li class="indented0 " name="fs2.kafka.TransactionalKafkaProducer#stream" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="stream[F[_],K,V](settings:fs2.kafka.TransactionalProducerSettings[F,K,V])(implicitF:cats.effect.Async[F],implicitmk:fs2.kafka.producer.MkProducer[F]):fs2.Stream[F,fs2.kafka.TransactionalKafkaProducer.WithoutOffsets[F,K,V]]" class="anchorToMember"></a><a id="stream[F[_],K,V](TransactionalProducerSettings[F,K,V])(Async[F],MkProducer[F]):Stream[F,WithoutOffsets[F,K,V]]" class="anchorToMember"></a> <span class="permalink"><a href="../../fs2/kafka/TransactionalKafkaProducer$.html#stream[F[_],K,V](settings:fs2.kafka.TransactionalProducerSettings[F,K,V])(implicitF:cats.effect.Async[F],implicitmk:fs2.kafka.producer.MkProducer[F]):fs2.Stream[F,fs2.kafka.TransactionalKafkaProducer.WithoutOffsets[F,K,V]]" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier"></span> <span class="kind">def</span></span> <span class="symbol"><span class="name">stream</span><span class="tparams">[<span name="F">F<span class="tparams">[<span name="_">_</span>]</span></span>, <span name="K">K</span>, <span name="V">V</span>]</span><span class="params">(<span name="settings">settings: <a href="TransactionalProducerSettings.html" name="fs2.kafka.TransactionalProducerSettings" id="fs2.kafka.TransactionalProducerSettings" class="extype">TransactionalProducerSettings</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.K" class="extype">K</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.V" class="extype">V</span>]</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="F">F: <span name="cats.effect.Async" class="extype">Async</span>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>]</span>, <span name="mk">mk: <a href="producer/MkProducer.html" name="fs2.kafka.producer.MkProducer" id="fs2.kafka.producer.MkProducer" class="extype">MkProducer</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>]</span>)</span><span class="result">: <a href="https://www.javadoc.io/doc/co.fs2/fs2-docs_2.13/3.9.4/fs2/Stream.html#fs2.Stream" name="fs2.Stream" id="fs2.Stream" class="extype">Stream</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>, <a href="TransactionalKafkaProducer$$WithoutOffsets.html" name="fs2.kafka.TransactionalKafkaProducer.WithoutOffsets" id="fs2.kafka.TransactionalKafkaProducer.WithoutOffsets" class="extype">WithoutOffsets</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.K" class="extype">K</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.V" class="extype">V</span>]]</span></span><p class="shortcomment cmt">Creates a new <a href="TransactionalKafkaProducer.html" name="fs2.kafka.TransactionalKafkaProducer" id="fs2.kafka.TransactionalKafkaProducer" class="extype">TransactionalKafkaProducer</a> in the <code>Stream</code> context, using the specified
+following syntax.</p><pre>TransactionalKafkaProducer.resource[F].using(settings)</pre></div></div></li><li class="indented0 " name="fs2.kafka.TransactionalKafkaProducer#stream" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="stream[F[_],K,V](settings:fs2.kafka.TransactionalProducerSettings[F,K,V])(implicitF:cats.effect.Async[F],implicitmk:fs2.kafka.producer.MkProducer[F]):fs2.Stream[F,fs2.kafka.TransactionalKafkaProducer.WithoutOffsets[F,K,V]]" class="anchorToMember"></a><a id="stream[F[_],K,V](TransactionalProducerSettings[F,K,V])(Async[F],MkProducer[F]):Stream[F,WithoutOffsets[F,K,V]]" class="anchorToMember"></a> <span class="permalink"><a href="../../fs2/kafka/TransactionalKafkaProducer$.html#stream[F[_],K,V](settings:fs2.kafka.TransactionalProducerSettings[F,K,V])(implicitF:cats.effect.Async[F],implicitmk:fs2.kafka.producer.MkProducer[F]):fs2.Stream[F,fs2.kafka.TransactionalKafkaProducer.WithoutOffsets[F,K,V]]" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier"></span> <span class="kind">def</span></span> <span class="symbol"><span class="name">stream</span><span class="tparams">[<span name="F">F<span class="tparams">[<span name="_">_</span>]</span></span>, <span name="K">K</span>, <span name="V">V</span>]</span><span class="params">(<span name="settings">settings: <a href="TransactionalProducerSettings.html" name="fs2.kafka.TransactionalProducerSettings" id="fs2.kafka.TransactionalProducerSettings" class="extype">TransactionalProducerSettings</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.K" class="extype">K</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.V" class="extype">V</span>]</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="F">F: <span name="cats.effect.Async" class="extype">Async</span>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>]</span>, <span name="mk">mk: <a href="producer/MkProducer.html" name="fs2.kafka.producer.MkProducer" id="fs2.kafka.producer.MkProducer" class="extype">MkProducer</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>]</span>)</span><span class="result">: <a href="https://www.javadoc.io/doc/co.fs2/fs2-docs_2.13/3.10.0/fs2/Stream.html#fs2.Stream" name="fs2.Stream" id="fs2.Stream" class="extype">Stream</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>, <a href="TransactionalKafkaProducer$$WithoutOffsets.html" name="fs2.kafka.TransactionalKafkaProducer.WithoutOffsets" id="fs2.kafka.TransactionalKafkaProducer.WithoutOffsets" class="extype">WithoutOffsets</a>[<span name="fs2.kafka.TransactionalKafkaProducer.stream.F" class="extype">F</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.K" class="extype">K</span>, <span name="fs2.kafka.TransactionalKafkaProducer.stream.V" class="extype">V</span>]]</span></span><p class="shortcomment cmt">Creates a new <a href="TransactionalKafkaProducer.html" name="fs2.kafka.TransactionalKafkaProducer" id="fs2.kafka.TransactionalKafkaProducer" class="extype">TransactionalKafkaProducer</a> in the <code>Stream</code> context, using the specified
 <a href="TransactionalProducerSettings.html" name="fs2.kafka.TransactionalProducerSettings" id="fs2.kafka.TransactionalProducerSettings" class="extype">TransactionalProducerSettings</a>.</p><div class="fullcomment"><div class="comment cmt"><p>Creates a new <a href="TransactionalKafkaProducer.html" name="fs2.kafka.TransactionalKafkaProducer" id="fs2.kafka.TransactionalKafkaProducer" class="extype">TransactionalKafkaProducer</a> in the <code>Stream</code> context, using the specified
 <a href="TransactionalProducerSettings.html" name="fs2.kafka.TransactionalProducerSettings" id="fs2.kafka.TransactionalProducerSettings" class="extype">TransactionalProducerSettings</a>. Note that there is another version where <code>F[_]</code> is
 specified explicitly and the key and value type can be inferred, which allows you to use the

api/fs2/kafka/consumer/KafkaAssignment.html

@@ -7,7 +7,7 @@
 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.13/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.4/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.13/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
+  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.13/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.10.0/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.13/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
 consumer.</p><div class="fullcomment"><div class="comment cmt"><p><code>Stream</code> where the elements are the set of <code>TopicPartition</code>s currently assigned to this
 consumer. The stream emits whenever a rebalance changes partition assignments.
 </p></div></div></li></ol></div><div class="values members"><h3>Concrete Value Members</h3><ol><li class="indented0 " name="scala.AnyRef#!=" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="!=(x$1:Any):Boolean" class="anchorToMember"></a><a id="!=(Any):Boolean" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html#!=(x$1:Any):Boolean" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">final </span> <span class="kind">def</span></span> <span class="symbol"><span class="name" title="gt4s: $bang$eq">!=</span><span class="params">(<span name="arg0">arg0: <a href="https://www.scala-lang.org/api/2.13.13/scala/Any.html#scala.Any" name="scala.Any" id="scala.Any" class="extype">Any</a></span>)</span><span class="result">: <a href="https://www.scala-lang.org/api/2.13.13/scala/Boolean.html#scala.Boolean" name="scala.Boolean" id="scala.Boolean" class="extype">Boolean</a></span></span><div class="fullcomment"><dl class="attributes block"><dt>Definition Classes</dt><dd>AnyRef → Any</dd></dl></div></li><li class="indented0 " name="scala.AnyRef###" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="##:Int" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html###:Int" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">final </span> <span class="kind">def</span></span> <span class="symbol"><span class="name" title="gt4s: $hash$hash">##</span><span class="result">: <a href="https://www.scala-lang.org/api/2.13.13/scala/Int.html#scala.Int" name="scala.Int" id="scala.Int" class="extype">Int</a></span></span><div class="fullcomment"><dl class="attributes block"><dt>Definition Classes</dt><dd>AnyRef → Any</dd></dl></div></li><li class="indented0 " name="scala.AnyRef#==" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="==(x$1:Any):Boolean" class="anchorToMember"></a><a id="==(Any):Boolean" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html#==(x$1:Any):Boolean" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">final </span> <span class="kind">def</span></span> <span class="symbol"><span class="name" title="gt4s: $eq$eq">==</span><span class="params">(<span name="arg0">arg0: <a href="https://www.scala-lang.org/api/2.13.13/scala/Any.html#scala.Any" name="scala.Any" id="scala.Any" class="extype">Any</a></span>)</span><span class="result">: <a href="https://www.scala-lang.org/api/2.13.13/scala/Boolean.html#scala.Boolean" name="scala.Boolean" id="scala.Boolean" class="extype">Boolean</a></span></span><div class="fullcomment"><dl class="attributes block"><dt>Definition Classes</dt><dd>AnyRef → Any</dd></dl></div></li><li class="indented0 " name="scala.Any#asInstanceOf" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="asInstanceOf[T0]:T0" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html#asInstanceOf[T0]:T0" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier">final </span> <span class="kind">def</span></span> <span class="symbol"><span class="name">asInstanceOf</span><span class="tparams">[<span name="T0">T0</span>]</span><span class="result">: <span name="scala.Any.asInstanceOf.T0" class="extype">T0</span></span></span><div class="fullcomment"><dl class="attributes block"><dt>Definition Classes</dt><dd>Any</dd></dl></div></li><li class="indented0 " name="fs2.kafka.consumer.KafkaAssignment#assign" group="Ungrouped" fullComment="yes" data-isabs="false" visbl="pub"><a id="assign(topic:String,partitions:cats.data.NonEmptySet[Int]):F[Unit]" class="anchorToMember"></a><a id="assign(String,NonEmptySet[Int]):F[Unit]" class="anchorToMember"></a> <span class="permalink"><a href="../../../fs2/kafka/consumer/KafkaAssignment.html#assign(topic:String,partitions:cats.data.NonEmptySet[Int]):F[Unit]" title="Permalink"><i class="material-icons"></i></a></span> <span class="modifier_kind"><span class="modifier"></span> <span class="kind">def</span></span> <span class="symbol"><span class="name">assign</span><span class="params">(<span name="topic">topic: <span name="scala.Predef.String" class="extype">String</span></span>, <span name="partitions">partitions: <span name="cats.data.NonEmptySet" class="extype">NonEmptySet</span>[<a href="https://www.scala-lang.org/api/2.13.13/scala/Int.html#scala.Int" name="scala.Int" id="scala.Int" class="extype">Int</a>]</span>)</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.13/scala/Unit.html#scala.Unit" name="scala.Unit" id="scala.Unit" class="extype">Unit</a>]</span></span><p class="shortcomment cmt">Manually assigns the specified list of partitions for the specified topic to the consumer.</p><div class="fullcomment"><div class="comment cmt"><p>Manually assigns the specified list of partitions for the specified topic to the consumer.