root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Add implicit for Serde[UUID] to Streams Scala API (#8335) 

Reviewers: Matthias J. Sax <matthias@confluent.io>
This commit is contained in:
Vladimir Korenev 2022-12-28 14:54:22 -08:00 committed by GitHub
parent 5f1810209f
commit eeedde7ea9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
View File

@ -37,6 +37,7 @@ object Serdes {
implicit def JavaDouble: Serde[java.lang.Double] = JSerdes.Double() implicit def JavaDouble: Serde[java.lang.Double] = JSerdes.Double()
implicit def Integer: Serde[Int] = JSerdes.Integer().asInstanceOf[Serde[Int]] implicit def Integer: Serde[Int] = JSerdes.Integer().asInstanceOf[Serde[Int]]
implicit def JavaInteger: Serde[java.lang.Integer] = JSerdes.Integer() 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] = implicit def timeWindowedSerde[T](implicit tSerde: Serde[T]): WindowedSerdes.TimeWindowedSerde[T] =
new WindowedSerdes.TimeWindowedSerde[T](tSerde) new WindowedSerdes.TimeWindowedSerde[T](tSerde)