From 5aa90d7ada9b058ee8602194440253e2b5d69853 Mon Sep 17 00:00:00 2001
From: Ben Plommer <ben.plommer@gmail.com>
Date: Tue, 15 Mar 2022 09:22:57 +0000
Subject: [PATCH] scalafmt

---
 .../test/scala/fs2/kafka/KafkaConsumerSpec.scala  | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
index d1cbda793..a3c0ff1f7 100644
--- a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
@@ -9,7 +9,11 @@ import cats.effect.unsafe.implicits.global
 import fs2.Stream
 import fs2.concurrent.SignallingRef
 import fs2.kafka.internal.converters.collection._
-import org.apache.kafka.clients.consumer.{ConsumerConfig, CooperativeStickyAssignor, NoOffsetForPartitionException}
+import org.apache.kafka.clients.consumer.{
+  ConsumerConfig,
+  CooperativeStickyAssignor,
+  NoOffsetForPartitionException
+}
 import org.apache.kafka.common.TopicPartition
 import org.apache.kafka.common.errors.TimeoutException
 import org.scalatest.Assertion
@@ -559,7 +563,9 @@ final class KafkaConsumerSpec extends BaseKafkaSpec {
                 .stream(
                   consumerSettings[IO]
                     .withProperties(
-                      ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG -> classOf[CooperativeStickyAssignor].getName
+                      ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG -> classOf[
+                        CooperativeStickyAssignor
+                      ].getName
                     )
                 )
                 .subscribeTo(topic)
@@ -801,9 +807,10 @@ final class KafkaConsumerSpec extends BaseKafkaSpec {
               .stream(
                 consumerSettings[IO]
                   .withProperties(
-                    ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG -> classOf[CooperativeStickyAssignor].getName
+                    ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG -> classOf[
+                      CooperativeStickyAssignor
+                    ].getName
                   )
-
               )
               .subscribeTo(topic)
               .evalMap { consumer =>