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 <mailinglist...@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.
>
>
>
