dajac commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1356448238
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorLoader.java:
##########
@@ -46,6 +46,50 @@ public short unknownType() {
}
}
+ /**
+ * Object that is returned as part of the future from load(). Holds the
partition load time and the
+ * end time.
+ */
+ class LoadSummary {
+ private final long startTimeMs;
+ private final long endTimeMs;
+ private final long numRecords;
+ private final long numBytes;
+
+ public LoadSummary(long startTimeMs, long endTimeMs, long numRecords,
long numBytes) {
+ this.startTimeMs = startTimeMs;
+ this.endTimeMs = endTimeMs;
+ this.numRecords = numRecords;
+ this.numBytes = numBytes;
+ }
+
+ public long startTimeMs() {
+ return startTimeMs;
+ }
+
+ public long endTimeMs() {
+ return endTimeMs;
+ }
+
+ public long numRecords() {
+ return numRecords;
+ }
+
+ public long numBytes() {
+ return numBytes;
+ }
+
Review Comment:
nit: We could remove an empty line here.
--
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
