Update a default partition.assignment.strategy to match Kafka 3.x.x (#…

…391)
evolution-gaming · Nov 13, 2023 · 9abd57e · 9abd57e
1 parent cbdc095
commit 9abd57e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConfig.scala b/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConfig.scala
@@ -20,7 +20,7 @@ final case class ConsumerConfig(
   heartbeatInterval: FiniteDuration          = 3.seconds,
   autoCommit: Boolean                        = true,
   autoCommitInterval: Option[FiniteDuration] = None,
-  partitionAssignmentStrategy: String        = "org.apache.kafka.clients.consumer.RangeAssignor",
+  partitionAssignmentStrategy: String        = "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
   autoOffsetReset: AutoOffsetReset           = AutoOffsetReset.Latest,
   defaultApiTimeout: FiniteDuration          = 1.minute,
   fetchMinBytes: Int                         = 1,

diff --git a/skafka/src/test/scala/com/evolutiongaming/skafka/consumer/ConsumerConfigSpec.scala b/skafka/src/test/scala/com/evolutiongaming/skafka/consumer/ConsumerConfigSpec.scala
@@ -104,7 +104,7 @@ class ConsumerConfigSpec extends AnyFunSuite with Matchers {
       "exclude.internal.topics"                  -> "true",
       "reconnect.backoff.max.ms"                 -> "1000",
       "auto.offset.reset"                        -> "latest",
-      "partition.assignment.strategy"            -> "org.apache.kafka.clients.consumer.RangeAssignor",
+      "partition.assignment.strategy"            -> "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
       "heartbeat.interval.ms"                    -> "3000",
       "check.crcs"                               -> "true",
       "auto.commit.interval.ms"                  -> "5000",