root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-16752: [MINOR] Addressed additional review comments (#16891) 

Reviewers: Andrew Schofield <aschofield@confluent.io>, Jun Rao <junrao@gmail.com>
This commit is contained in:
Apoorv Mittal 2024-08-15 22:36:39 +01:00 committed by GitHub
parent 21dd5cd421
commit 011d35237c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/java/kafka/server/share/SharePartition.java
View File

@ -1163,7 +1163,7 @@ public class SharePartition {
inFlightBatch, groupId, topicIdPartition); inFlightBatch, groupId, topicIdPartition);
return Optional.of(new InvalidRecordStateException("The batch cannot be acknowledged. The subset batch is not in the acquired state.")); 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. // the offsets state in the in-flight batch.
inFlightBatch.maybeInitializeOffsetStateUpdate(); inFlightBatch.maybeInitializeOffsetStateUpdate();
} }