This is an automated email from the ASF dual-hosted git repository.
mittal pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a663ce3f457 KAFKA-18265: Move acquisition lock classes from share
partition (1/N) (#20227)
add d350f603a4a KAFKA-18265: Move inflight batch and state classes from
SharePartition (2/N) (#20230)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/SharePartition.java | 448 +++------------------
.../kafka/server/share/SharePartitionTest.java | 43 +-
...yedShareFetchKey.java => DeliveryCountOps.java} | 8 +-
.../kafka/server/share/fetch/InFlightBatch.java | 255 ++++++++++++
.../kafka/server/share/fetch/InFlightState.java | 237 +++++++++++
.../kafka/server/share/fetch/RecordState.java | 82 ++++
.../kafka/server/share/fetch/RecordStateTest.java | 64 +++
7 files changed, 691 insertions(+), 446 deletions(-)
copy
server/src/main/java/org/apache/kafka/server/share/fetch/{DelayedShareFetchKey.java
=> DeliveryCountOps.java} (81%)
create mode 100644
server/src/main/java/org/apache/kafka/server/share/fetch/InFlightBatch.java
create mode 100644
server/src/main/java/org/apache/kafka/server/share/fetch/InFlightState.java
create mode 100644
server/src/main/java/org/apache/kafka/server/share/fetch/RecordState.java
create mode 100644
server/src/test/java/org/apache/kafka/server/share/fetch/RecordStateTest.java
