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

…efault
evolution-gaming · Nov 13, 2023 · ba997a8 · ba997a8
1 parent cbdc095
commit ba997a8
Showing 1 changed file with 1 addition and 1 deletion.
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,