-----BEGIN PGP SIGNATURE-----
Comment: GPGTools - https://gpgtools.org
iQIzBAEBCgAdFiEE8osu2CcCCF5douGQu8PBaGu5w1EFAl270U4ACgkQu8PBaGu5
w1FZrA/+PkZjuo/WxEjxh+5lwUubzTGJ7Wx9y4f21N69f4cQpDK2C0n52qlWgXAF
YcmGcSEfDc25EE9AW5MkB41wMhpGkc1vtt4U/O2WMQ/PTcesd8ME+a+sIqkiexuN
GscElxbAcaq/Gvbh+MEul1biq5LfibN0UsobRUTqIEsKxmllzqmbi2Vw+saIprtN
1/yPhVQbdGPXqwY+P3OOEig0ewu0/+1/JqkHN9OkKAebrRxkjKqb6tCTO6ql0RS7
/CvHkyPZZ00lLpssk/H57NSYDInjgi4PrC7EQyDxeOz3MqDZziXW1eXoQ913srMI
o4KbgHmD0ujqLC0pn/yL1lUi5w6o0Hgy8Uzot3AVnE2QsIyDckDHSloevN6xYxYV
e7P0Yx9kBzB0IxJOYJUMy5KM7xDPDu0PPQfeR9sVThJFFusu5kP5fRFDTrKmtfBu
VUwMd+kXuKqZEnQrSR2esR847vGcDwh4EGM42krrNEgLr05mKRpUjza6HEhinXuk
r1eHNGh4KVCSoUWMXudnotDDf4xArLKz8m0ofqaTkE9maw/MdM5BoZiz6oB45e8s
h7XPTZFtoXlLerDf2KudW9Sb7QNsckqJm3BilmeiiGGyal5coacLmOB0+xnEqLLz
x4cJSD4F4+kJPxfDnH+QPlkz2SMMHiCBpOGETZg1fBQpS1p9utY=
=QeX3
-----END PGP SIGNATURE-----
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()`.
-Matthias
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
Comment: GPGTools - https://gpgtools.org
iQIzBAEBCgAdFiEE8osu2CcCCF5douGQu8PBaGu5w1EFAl270U4ACgkQu8PBaGu5
w1FZrA/+PkZjuo/WxEjxh+5lwUubzTGJ7Wx9y4f21N69f4cQpDK2C0n52qlWgXAF
YcmGcSEfDc25EE9AW5MkB41wMhpGkc1vtt4U/O2WMQ/PTcesd8ME+a+sIqkiexuN
GscElxbAcaq/Gvbh+MEul1biq5LfibN0UsobRUTqIEsKxmllzqmbi2Vw+saIprtN
1/yPhVQbdGPXqwY+P3OOEig0ewu0/+1/JqkHN9OkKAebrRxkjKqb6tCTO6ql0RS7
/CvHkyPZZ00lLpssk/H57NSYDInjgi4PrC7EQyDxeOz3MqDZziXW1eXoQ913srMI
o4KbgHmD0ujqLC0pn/yL1lUi5w6o0Hgy8Uzot3AVnE2QsIyDckDHSloevN6xYxYV
e7P0Yx9kBzB0IxJOYJUMy5KM7xDPDu0PPQfeR9sVThJFFusu5kP5fRFDTrKmtfBu
VUwMd+kXuKqZEnQrSR2esR847vGcDwh4EGM42krrNEgLr05mKRpUjza6HEhinXuk
r1eHNGh4KVCSoUWMXudnotDDf4xArLKz8m0ofqaTkE9maw/MdM5BoZiz6oB45e8s
h7XPTZFtoXlLerDf2KudW9Sb7QNsckqJm3BilmeiiGGyal5coacLmOB0+xnEqLLz
x4cJSD4F4+kJPxfDnH+QPlkz2SMMHiCBpOGETZg1fBQpS1p9utY=
=QeX3
-----END PGP SIGNATURE-----
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()`.
-Matthias
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
Comments
Post a Comment