From aa3dff171a31449491e89299db6f8fc1aae649a2 Mon Sep 17 00:00:00 2001 From: Docusaurus bot Date: Sat, 28 Oct 2023 10:10:52 +0000 Subject: [PATCH] Deploy website Deploy website version based on b3338aafb1ade93ecaf7c118245d57b7faad92c7 --- api/fs2/kafka/ConsumerSettings.html | 2 +- api/fs2/kafka/KafkaConsumer.html | 2 +- api/fs2/kafka/consumer/KafkaAssignment.html | 2 +- docs/overview.html | 2 +- docs/overview/index.html | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/api/fs2/kafka/ConsumerSettings.html b/api/fs2/kafka/ConsumerSettings.html index 9c8c5d80e..861efe2d0 100644 --- a/api/fs2/kafka/ConsumerSettings.html +++ b/api/fs2/kafka/ConsumerSettings.html @@ -15,7 +15,7 @@ records are being processed, there can be up to maxPrefetchBatches * max.poll.records records per topic-partition that have already been fetched, and are waiting to be processed. You can use withMaxPollRecords to control the max.poll.records setting.

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.

Note that prefetching cannot be disabled and is generally preferred since it yields improved performance. The minimum value for this setting is 2.

  • abstract def pollInterval: FiniteDuration

    How often we should attempt to call poll on the Java KafkaConsumer.

    How often we should attempt to call poll on the Java KafkaConsumer.

    The default value is 50 milliseconds. diff --git a/api/fs2/kafka/KafkaConsumer.html b/api/fs2/kafka/KafkaConsumer.html index ce0c2b00e..582bb3242 100644 --- a/api/fs2/kafka/KafkaConsumer.html +++ b/api/fs2/kafka/KafkaConsumer.html @@ -26,7 +26,7 @@ one).

    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 assign and group assigment with subscribe.

    If auto-commit is enabled, an async commit (based on the old assignment) will be triggered +partition assignment with assign and group assignment with subscribe.

    If auto-commit is enabled, an async commit (based on the old assignment) will be triggered before the new assignment replaces the old one.

    To unassign all partitions, use KafkaConsumer#unsubscribe.

    Definition Classes
    KafkaAssignment
    See also

    org.apache.kafka.clients.consumer.KafkaConsumer#assign

  • abstract def assignment: F[SortedSet[TopicPartition]]

    Returns the set of partitions currently assigned to this consumer.

    Returns the set of partitions currently assigned to this consumer. diff --git a/api/fs2/kafka/consumer/KafkaAssignment.html b/api/fs2/kafka/consumer/KafkaAssignment.html index aa078bd43..1f86b033f 100644 --- a/api/fs2/kafka/consumer/KafkaAssignment.html +++ b/api/fs2/kafka/consumer/KafkaAssignment.html @@ -4,7 +4,7 @@ one).

    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 assign and group assigment with subscribe.

    If auto-commit is enabled, an async commit (based on the old assignment) will be triggered +partition assignment with assign and group assignment with subscribe.

    If auto-commit is enabled, an async commit (based on the old assignment) will be triggered before the new assignment replaces the old one.

    To unassign all partitions, use KafkaConsumer#unsubscribe.

    See also

    org.apache.kafka.clients.consumer.KafkaConsumer#assign

  • abstract def assignment: F[SortedSet[TopicPartition]]

    Returns the set of partitions currently assigned to this consumer.

  • abstract def assignmentStream: Stream[F, SortedSet[TopicPartition]]

    Stream where the elements are the set of TopicPartitions currently assigned to this diff --git a/docs/overview.html b/docs/overview.html index f565265b2..3f8ebb4ff 100644 --- a/docs/overview.html +++ b/docs/overview.html @@ -84,7 +84,7 @@

    resolvers += Resolver.sonatypeRepo("snapshots") -libraryDependencies += "com.github.fd4s" %% "fs2-kafka" % "3.2.0-2-15d32d9-SNAPSHOT" +libraryDependencies += "com.github.fd4s" %% "fs2-kafka" % "3.2.0-3-b3338aa-SNAPSHOT"

    Dependencies

    Refer to the table below for dependencies and version support across modules.

    diff --git a/docs/overview/index.html b/docs/overview/index.html index f565265b2..3f8ebb4ff 100644 --- a/docs/overview/index.html +++ b/docs/overview/index.html @@ -84,7 +84,7 @@

    resolvers += Resolver.sonatypeRepo("snapshots") -libraryDependencies += "com.github.fd4s" %% "fs2-kafka" % "3.2.0-2-15d32d9-SNAPSHOT" +libraryDependencies += "com.github.fd4s" %% "fs2-kafka" % "3.2.0-3-b3338aa-SNAPSHOT"

    Dependencies

    Refer to the table below for dependencies and version support across modules.