From eeedde7ea9d3ba6c19e4dc8a96610f9cb0851d82 Mon Sep 17 00:00:00 2001 From: Vladimir Korenev Date: Wed, 28 Dec 2022 14:54:22 -0800 Subject: [PATCH] MINOR: Add implicit for Serde[UUID] to Streams Scala API (#8335) Reviewers: Matthias J. Sax --- .../src/main/scala/org/apache/kafka/streams/scala/Serdes.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala index 2e42090d13d..d3cc61279c8 100644 --- a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala +++ b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala @@ -37,6 +37,7 @@ object Serdes { implicit def JavaDouble: Serde[java.lang.Double] = JSerdes.Double() implicit def Integer: Serde[Int] = JSerdes.Integer().asInstanceOf[Serde[Int]] implicit def JavaInteger: Serde[java.lang.Integer] = JSerdes.Integer() + implicit def UUID: Serde[util.UUID] = JSerdes.UUID() implicit def timeWindowedSerde[T](implicit tSerde: Serde[T]): WindowedSerdes.TimeWindowedSerde[T] = new WindowedSerdes.TimeWindowedSerde[T](tSerde)