kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: serdeProps what does that mean
Date Fri, 01 Nov 2019 06:31:34 GMT
I guess that should be possible. Kafka Streams would not (de)serialize
it's configuration `Properties` but forward them as pass-by-reference to
the `Serde#configure()`.


On 10/31/19 5:36 AM, Bart van Deenen wrote:
> Hi I'm sorry for the confusion.
> My question should be 'are there limitations on what you can put in this configuration
map' ?
> Could you put objects with state in the map for instance? Will this map be serialized
> Thanks
> On Thu, Oct 31, 2019, at 10:35, Matthias J. Sax wrote:
>> 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
>> Attachments:
>> * signature.asc

View raw message