ijuma commented on code in PR #13582:
URL: https://github.com/apache/kafka/pull/13582#discussion_r1236054069
##########
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java:
##########
@@ -431,7 +431,7 @@ private static void skipBytes(InputStream in, int
bytesToSkip) throws IOExceptio
// Starting JDK 12, this implementation could be replaced by
InputStream#skipNBytes
while (bytesToSkip > 0) {
- long ns = in.skip(bytesToSkip);
+ int ns = (int) in.skip(bytesToSkip);
Review Comment:
New issue introduced in trunk after this PR was originally created. There
are a few others, but I'll address them together with the JDK 20 CI build
(which will prevent the issue altogether).
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
