Hi all

I need a custom serde for Kafka. Our serde needs a SchemaStore instance with 
some state, and I'm trying to figure out how to get this into the serde.
I'm trying to follow along with this example
https://github.com/apache/kafka/blob/ad5f31c3e6868757eab9c8dd71efd5fd65f06ac6/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java#L102

and I don't understand what the configure method does. What is it for, and what 
can I stick in the map? Following along with the example, I see that 
`serdeProps` sets the `tClass` field to the class that you want to 
(de)serialize. Why?

Thanks

Bart

Reply via email to