frankvicky commented on code in PR #17579:
URL: https://github.com/apache/kafka/pull/17579#discussion_r1833634453
##########
test-common/src/main/java/org/apache/kafka/common/test/TestUtils.java:
##########
@@ -125,4 +148,131 @@ static void retryOnExceptionWithTimeout(final Runnable
runnable) throws Interrup
Thread.sleep(DEFAULT_POLL_INTERVAL_MS);
}
}
+
+ /**
+ * Wrap a single record log buffer.
+ */
+ public static MemoryRecords singletonRecords(byte[] value,
Review Comment:
These helper methods come from `TestUtils.scala`. In the Scala version, they
are widely used across many test classes. Considering that we will eventually
drop Scala, I think we could retain these helper methods in `TestUtils.java`.
--
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
