Skip to content

Commit 5070bca

Browse files
authored
Update a default partition.assignment.strategy to match Kafka 3.x.x default (#392)
1 parent 7b2d09e commit 5070bca

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConfig.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ final case class ConsumerConfig(
2020
heartbeatInterval: FiniteDuration = 3.seconds,
2121
autoCommit: Boolean = true,
2222
autoCommitInterval: Option[FiniteDuration] = None,
23-
partitionAssignmentStrategy: String = "org.apache.kafka.clients.consumer.RangeAssignor",
23+
partitionAssignmentStrategy: String = "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
2424
autoOffsetReset: AutoOffsetReset = AutoOffsetReset.Latest,
2525
defaultApiTimeout: FiniteDuration = 1.minute,
2626
fetchMinBytes: Int = 1,

skafka/src/test/scala/com/evolutiongaming/skafka/consumer/ConsumerConfigSpec.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ class ConsumerConfigSpec extends AnyFunSuite with Matchers {
104104
"exclude.internal.topics" -> "true",
105105
"reconnect.backoff.max.ms" -> "1000",
106106
"auto.offset.reset" -> "latest",
107-
"partition.assignment.strategy" -> "org.apache.kafka.clients.consumer.RangeAssignor",
107+
"partition.assignment.strategy" -> "org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
108108
"heartbeat.interval.ms" -> "3000",
109109
"check.crcs" -> "true",
110110
"auto.commit.interval.ms" -> "5000",

0 commit comments

Comments
 (0)