zheguang commented on code in PR #21706:
URL: https://github.com/apache/kafka/pull/21706#discussion_r2935078248
##########
streams/src/main/java/org/apache/kafka/streams/state/internals/Utils.java:
##########
@@ -50,6 +58,21 @@ static byte[] rawPlainValue(final byte[]
rawValueTimestampHeaders) {
return result;
}
+ private static boolean hasEmptyHeadersAndTimestamp(final byte[]
rawValueTimestampHeaders) {
Review Comment:
Actualy... it does check a little something about the timestamp -- that the
input is at least longer than the timestamp size. Line 64 is the relevant bit:
```
if (rawValueTimestampHeaders.length - 1 - StateSerdes.TIMESTAMP_SIZE < 0)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
