[
https://issues.apache.org/jira/browse/KAFKA-20173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18063812#comment-18063812
]
Matthias J. Sax commented on KAFKA-20173:
-----------------------------------------
We have an open question on
[https://github.com/apache/kafka/pull/21536#discussion_r2836378598] – need to
cycle back to re-evaluate how to handle it.
> 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)
