Kafka Streams: Creating Serde in Scala for application specific object

[Eric Beabes <ma...@gmail.com>]

I am grouping messages as follows:

.groupBy((_, myAppObject) => myAppObject.getId)(Grouped.`with`[String,
MyAppObject])


I am getting a message saying.. "No implicits found for parameter
valueSerde: Serde[MyAppObject]


My understanding is I need to add an implicit like this...


implicit val *mySerde*:Serde[MyAppObject] = Serdes.fromFn(...)


But I don't know how to create a Serde for MyAppObject. Am I supposed
to use 'fromFn'? I couldn't find any examples. Any tips would be
greatly appreciated!


Thanks.

Re: Kafka Streams: Creating Serde in Scala for application specific object

[Eric Beabes <ma...@gmail.com>]

Don't worry about this one. Figured it out. Created a Serde for MyAppObject
& implemented my own Serializer & Deserializer classes.

object MyAppObjectSerde extends Serde[MyAppObject] {

  override def serializer(): Serializer[MyAppObject] = new MyAppObjectSerializer

  override def deserializer(): Deserializer[MyAppObject] = new
MyAppObjectDeserializer

}


On Tue, Dec 1, 2020 at 1:33 PM Eric Beabes <ma...@gmail.com> wrote:

> I am grouping messages as follows:
>
> .groupBy((_, myAppObject) => myAppObject.getId)(Grouped.`with`[String, MyAppObject])
>
>
> I am getting a message saying.. "No implicits found for parameter valueSerde: Serde[MyAppObject]
>
>
> My understanding is I need to add an implicit like this...
>
>
> implicit val *mySerde*:Serde[MyAppObject] = Serdes.fromFn(...)
>
>
> But I don't know how to create a Serde for MyAppObject. Am I supposed to use 'fromFn'? I couldn't find any examples. Any tips would be greatly appreciated!
>
>
> Thanks.
>
>
>