[ 
https://issues.apache.org/jira/browse/KAFKA-20155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18063737#comment-18063737
 ] 

Muralidhar Basani commented on KAFKA-20155:
-------------------------------------------

[~frankvicky]  I see the change in the changelog stores 
(ChangeLoggingSessionBytesStoreWithHeaders, 
ChangeLoggingTimestampedKeyValueBytesStoreWithHeaders & 
ChangeLoggingTimestampedWindowBytesStoreWithHeaders) by extracting raw header 
bytes instead of fully parsing them into Headers objects. 

I also want to introduce a lazy SerializedHeaders wrapper (interface 
implementing Headers) that defers deserialization until the producer actually 
needs the header data, and supports add() (for vector clock entry) without 
deserializing existing headers. 

I do not see any other interface changes. 

Shall I try picking this up ? Do you think there are any blocking tickets to 
this?

 

> Implement lazy deserialization mechanism
> ----------------------------------------
>
>                 Key: KAFKA-20155
>                 URL: https://issues.apache.org/jira/browse/KAFKA-20155
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: streams
>            Reporter: TengYao Chi
>            Priority: Major
>




--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to