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
ijuma commented on code in PR #13582:
URL: https://github.com/apache/kafka/pull/13582#discussion_r1236050527
##
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java:
##
@@ -34,7 +34,7 @@ public Short deserialize(String topic, byte[] data) {
ijuma commented on code in PR #13582:
URL: https://github.com/apache/kafka/pull/13582#discussion_r1225487332
##
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java:
##
@@ -128,11 +128,11 @@ public InputStream wrapForInput(ByteBuffer buffer, byte
messageVer
ijuma commented on code in PR #13582:
URL: https://github.com/apache/kafka/pull/13582#discussion_r1170050264
##
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java:
##
@@ -434,7 +434,7 @@ private static byte computeAttributes(CompressionType type,
Times