From ba997a8c2aa80c084292714594cd47245a8afe45 Mon Sep 17 00:00:00 2001 From: Z1kkurat Date: Mon, 13 Nov 2023 12:58:25 +0100 Subject: [PATCH] Update a default partition.assignment.strategy to match Kafka 3.x.x default --- .../com/evolutiongaming/skafka/consumer/ConsumerConfig.scala | 2 +- 1 file changed, 1 insertion(+), 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 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,