Well, the `configure()` method is there to configure the serde :) Hence, it might be a good place to instantiate the state of the serde, ie, to create a `SchemaStore` instance.
For the passed in map: the full `StreamsConfig` will be passed into it, hence, you can add any configuration you want to the global `KafkaStreams` configuration and it will be forwarded. Hope this helps. -Matthias On 10/28/19 5:34 AM, Bart van Deenen wrote: > 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 >
signature.asc
Description: OpenPGP digital signature
