From 011d35237c3454d24f1933791173ba211d037969 Mon Sep 17 00:00:00 2001 From: Apoorv Mittal Date: Thu, 15 Aug 2024 22:36:39 +0100 Subject: [PATCH] KAFKA-16752: [MINOR] Addressed additional review comments (#16891) Reviewers: Andrew Schofield , Jun Rao --- core/src/main/java/kafka/server/share/SharePartition.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/kafka/server/share/SharePartition.java b/core/src/main/java/kafka/server/share/SharePartition.java index df5df59ac49..8751e0100e4 100644 --- a/core/src/main/java/kafka/server/share/SharePartition.java +++ b/core/src/main/java/kafka/server/share/SharePartition.java @@ -1163,7 +1163,7 @@ public class SharePartition { inFlightBatch, groupId, topicIdPartition); return Optional.of(new InvalidRecordStateException("The batch cannot be acknowledged. The subset batch is not in the acquired state.")); } - // The request batch is a subset or per offset state is managed hence update + // The request batch is a subset and requires per offset state hence initialize // the offsets state in the in-flight batch. inFlightBatch.maybeInitializeOffsetStateUpdate(); }