This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 6b96273ba00 KAFKA-19345: Use ShareFetchUtils mock for
DelayedShareFetchTest tests (#20765)
add 23b809a8add KAFKA-19301 Move and rewrite partition state classes to
Java in org.apache.kafka.storage.internals.log (#20083)
No new revisions were added by this update.
Summary of changes:
.../kafka/server/share/SharePartitionManager.java | 2 +-
core/src/main/scala/kafka/cluster/Partition.scala | 214 ++++-----------------
.../group/CoordinatorPartitionWriter.scala | 3 +-
.../main/scala/kafka/server/ReplicaManager.scala | 4 +-
.../unit/kafka/cluster/AbstractPartitionTest.scala | 2 +-
.../unit/kafka/cluster/AssignmentStateTest.scala | 6 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 2 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 198 +++++++++----------
.../integration/UncleanLeaderElectionTest.scala | 2 +-
.../unit/kafka/server/MetadataCacheTest.scala | 2 +-
.../server/ReplicaManagerConcurrencyTest.scala | 2 +-
.../partition/PartitionMakeFollowerBenchmark.java | 2 +-
.../UpdateFollowerFetchStateBenchmark.java | 2 +-
.../org/apache/kafka/metadata/LeaderAndIsr.java | 6 +-
.../apache/kafka/metadata/LeaderAndIsrTest.java | 9 +-
...LastRecord.java => AlterPartitionListener.java} | 26 ++-
...ogOffsetsListener.java => AssignmentState.java} | 31 ++-
...tPosition.java => CommittedPartitionState.java} | 24 ++-
...uncation.java => OngoingReassignmentState.java} | 27 +--
.../storage/internals/log/PartitionListener.java | 63 ++++++
.../log/{AppendOrigin.java => PartitionState.java} | 29 +--
.../storage/internals/log/PendingExpandIsr.java | 67 +++++++
...ogReadInfo.java => PendingPartitionChange.java} | 17 +-
.../storage/internals/log/PendingShrinkIsr.java | 63 ++++++
...setPosition.java => SimpleAssignmentState.java} | 20 +-
25 files changed, 454 insertions(+), 369 deletions(-)
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{LastRecord.java
=> AlterPartitionListener.java} (63%)
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{LogOffsetsListener.java
=> AssignmentState.java} (54%)
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{OffsetPosition.java
=> CommittedPartitionState.java} (69%)
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{LogTruncation.java
=> OngoingReassignmentState.java} (55%)
create mode 100644
storage/src/main/java/org/apache/kafka/storage/internals/log/PartitionListener.java
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{AppendOrigin.java
=> PartitionState.java} (51%)
create mode 100644
storage/src/main/java/org/apache/kafka/storage/internals/log/PendingExpandIsr.java
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{LogReadInfo.java
=> PendingPartitionChange.java} (63%)
create mode 100644
storage/src/main/java/org/apache/kafka/storage/internals/log/PendingShrinkIsr.java
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{OffsetPosition.java
=> SimpleAssignmentState.java} (71%)
