Skip to content

Commit

Permalink
sbt fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
erikvanoosten committed Oct 15, 2023
1 parent 7703140 commit 003d4e0
Showing 1 changed file with 13 additions and 7 deletions.
20 changes: 13 additions & 7 deletions zio-kafka/src/main/scala/zio/kafka/consumer/ConsumerSettings.scala
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,12 @@ final case class ConsumerSettings(
*
* Sets poll timeout to 500 ms, `max.poll.records` to 2000 and `maxPartitionQueueSize` to 4096.
*
* @see [[ConsumerSettings.withPollTimeout]]
* @see [[ConsumerSettings.withMaxPollRecords]]
* @see [[zio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy]]
* @see
* [[ConsumerSettings.withPollTimeout]]
* @see
* [[ConsumerSettings.withMaxPollRecords]]
* @see
* [[zio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy]]
*/
def tuneForHighThroughput: ConsumerSettings =
this
Expand All @@ -55,9 +58,12 @@ final case class ConsumerSettings(
*
* Sets poll timeout to 50 ms, `max.poll.records` to 100 and `maxPartitionQueueSize` to 512.
*
* @see [[ConsumerSettings.withPollTimeout]]
* @see [[ConsumerSettings.withMaxPollRecords]]
* @see [[zio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy]]
* @see
* [[ConsumerSettings.withPollTimeout]]
* @see
* [[ConsumerSettings.withMaxPollRecords]]
* @see
* [[zio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy]]
*/
def tuneForLowLatency: ConsumerSettings =
this
Expand Down Expand Up @@ -178,7 +184,7 @@ final case class ConsumerSettings(
}

object ConsumerSettings {
val defaultCommitTimeout: Duration = 15.seconds
val defaultCommitTimeout: Duration = 15.seconds

def apply(bootstrapServers: List[String]) =
new ConsumerSettings().withBootstrapServers(bootstrapServers)
Expand Down

0 comments on commit 003d4e0

Please sign in to comment.