[
https://issues.apache.org/jira/browse/KAFKA-20173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-20173.
-------------------------------------
Resolution: Fixed
> Revisit KS serde code to check if headers are passed correctly
> --------------------------------------------------------------
>
> Key: KAFKA-20173
> URL: https://issues.apache.org/jira/browse/KAFKA-20173
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: TengYao Chi
> Assignee: Uladzislau Blok
> Priority: Major
> Fix For: 4.3.0
>
>
> Example of expected change:
> {{SessionWindowedDeserializer#deserialize(final String topic, final byte[]
> data)}}
> This is wrapper which is using underlying deserealizer:
> {{SessionKeySchema.from}} -> {{extractKey}} -> {{deserializer.deserialize}}
> The idea of this ticket is to find all call to serde method (serealize /
> deserialize) and propagate headers (or create them from bytes if needed)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
