将 Zio-Kafka 消费者与 Zio-Json 反序列化器集成

Question

我正在研究库 zio-kafka，我想使用 zio-json 以 JSON 格式反序列化消息的值。

我有一个简单的案例类以及它的解码器和编码器：

case class Player(name: String, score: Int)
object Player {
  implicit val decoder: JsonDecoder[Player] = DeriveJsonDecoder.gen[Player]
  implicit val encoder: JsonEncoder[Player] = DeriveJsonEncoder.gen[Player]
}

现在，我从使用上述解码器/编码器的Serde.string 开始创建了一个Serde：

val playerSerde: Serde[Any, Player] = Serde.string.inmapM { playerAsString =>
  ZIO.fromEither(playerAsString.fromJson[Player].left.map(new RuntimeException(_)))
} { playerAsObj =>
  ZIO.effect(playerAsObj.toJson)
}

正确吗？还有其他（更好的）方法吗？

Answer 1

考虑使用.getOrElse，因为我认为它使意图更清晰，并且避免了对左侧字段的裸访问：

  val playerSerde: Serde[Any, Player] = Serde.string.inmapM { playerAsString =>
    ZIO.effectTotal(playerAsString.fromJson[Player].getOrElse(throw new Error))
  }(playerAsObj => ZIO.effect(playerAsObj.toJson))

我还假设您的意思是 .fromJson[Player]，因为我在您的问题中没有看到 Match 类。