diff --git a/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConfig.scala b/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConfig.scala index 0195ce13..83090168 100644 --- 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,