Merge pull request #585 from CleverCloud/bump/deps

Bump deps

Author: judu

build.sbt

@@ -9,29 +9,29 @@ def publishVersion = if (isRelease) releaseVersion else if (isGithubActions) "2.
 val org = "com.clever-cloud.pulsar4s"
 val AkkaStreamVersion = "2.6.20" // compatible with Akka 2.5.x and 2.6.x
 val CatsEffectVersion = "3.5.3"
-val CirceVersion = "0.14.3"
+val CirceVersion = "0.14.6"
 val CommonsIoVersion = "2.4"
 val ExtsVersion = "1.61.1"
-val JacksonVersion = "2.14.1"
-val Log4jVersion = "2.22.0"
+val JacksonVersion = "2.14.3"
+val Log4jVersion = "2.22.1"
 val MonixVersion = "3.4.1"
-val PekkoStreamVersion = "1.0.0"
+val PekkoStreamVersion = "1.0.2"
 val PlayJsonVersion = "2.10.4"
-val PulsarVersion = "3.1.1"
+val PulsarVersion = "3.2.0"
 val ReactiveStreamsVersion = "1.0.2"
-val FunctionalStreamsVersion = "3.4.0"
+val FunctionalStreamsVersion = "3.9.4"
 val Json4sVersion = "4.0.7"
 // Version of Avro4s for Scala 2.X
 val Avro4sVersionFor2 = "4.1.1"
 // Version of Avro4s for Scala 3.X
-val Avro4sVersionFor3 = "5.0.3"
+val Avro4sVersionFor3 = "5.0.9"
 val ScalaVersion = "3.3.1"
 val ScalatestVersion = "3.2.17"
 val ScalazVersion = "7.2.35"
-val Slf4jVersion = "2.0.9"
+val Slf4jVersion = "2.0.11"
 val SprayJsonVersion = "1.3.6"
-val ZIOVersion = "2.0.19"
-val ZIOInteropCatsVersion = "23.0.0.8"
+val ZIOVersion = "2.0.21"
+val ZIOInteropCatsVersion = "23.0.03"
 
 lazy val commonScalaVersionSettings = Seq(
   scalaVersion := ScalaVersion,

project/build.properties

@@ -1 +1 @@
-sbt.version=1.9.7
+sbt.version=1.9.8

pulsar4s-circe/src/test/scala-3/com/sksamuel/pulsar4s/circe/CirceProducerConsumerTest.scala

@@ -36,13 +36,13 @@ class CirceProducerConsumerTest extends AnyFunSuite with Matchers {
     val topic = Topic("persistent://sample/standalone/ns1/test_" + UUID.randomUUID)
 
     val producer = client.producer[String](ProducerConfig(topic))
-    val messageId = producer.send("""{"foo": "bar"}""")
+    val messageId = producer.send("""{"not":"Cafe"}""")
     producer.close()
 
     val consumer = client.consumer[Cafe](ConsumerConfig(topics = Seq(topic), subscriptionName = Subscription.generate))
     consumer.seek(MessageId.earliest)
     val msg = consumer.receive
-    msg.get.valueTry shouldBe Failure(DecodingFailure("Cafe", List()))
+    msg.get.valueTry.isFailure shouldBe true
     consumer.close()
 
     client.close()