Fix for scala 2.12

zio · Nov 5, 2023 · c41344e · c41344e
1 parent 77ed9f9
commit c41344e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-kafka-test/src/test/scala/zio/kafka/consumer/ConsumerSpec.scala b/zio-kafka-test/src/test/scala/zio/kafka/consumer/ConsumerSpec.scala
@@ -648,7 +648,7 @@ object ConsumerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
                             .tap { record =>
                               // Signal consumer 2 can start when a record is seen for every partition.
                               for {
-                                keys <- c1Keys.updateAndGet(_.appended(record.key))
+                                keys <- c1Keys.updateAndGet(_ ++ record.key)
                                 _ <- c1Started.succeed(()).when(keys.map(_.split('-')(1)).toSet.size == partitionCount)
                               } yield ()
                             }