Hello,
I need knowledge on how to Serdes custom type like Instant , Date&Time in kafka streams.
I cannot find any forums to explain this.
In the end, you need to implement the Serializer, Deserializer, and Serde interface.
How you lay out the bytes, is up to you. And Instant
for example is basically a long
, so if you look into the LongSerializer and LongDeserializer code it may help.
1 Like