This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 00b1b1a1445 KAFKA-17628 New workflows for automating run approvals
(#17290)
add 05366d2fa7c KAFKA-17626: Move common fetch related classes from
storage to server-common (#17289)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 -
checkstyle/import-control-share.xml | 2 +-
core/src/main/java/kafka/log/remote/RemoteLogManager.java | 2 +-
core/src/main/java/kafka/server/share/DelayedShareFetch.java | 8 +++++---
core/src/main/java/kafka/server/share/ShareFetchUtils.java | 2 +-
core/src/main/java/kafka/server/share/SharePartition.java | 2 +-
core/src/main/java/kafka/server/share/SharePartitionManager.java | 2 +-
core/src/main/scala/kafka/cluster/Partition.scala | 3 ++-
.../scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala | 2 +-
.../main/scala/kafka/coordinator/group/GroupMetadataManager.scala | 3 ++-
.../kafka/coordinator/transaction/TransactionStateManager.scala | 3 ++-
core/src/main/scala/kafka/log/UnifiedLog.scala | 3 ++-
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala | 3 ++-
core/src/main/scala/kafka/server/DelayedFetch.scala | 3 ++-
core/src/main/scala/kafka/server/DelayedRemoteFetch.scala | 3 ++-
core/src/main/scala/kafka/server/KafkaApis.scala | 3 ++-
core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala | 2 +-
core/src/main/scala/kafka/server/ReplicaManager.scala | 3 ++-
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java | 2 +-
core/src/test/java/kafka/server/share/DelayedShareFetchTest.java | 4 ++--
core/src/test/java/kafka/server/share/ShareFetchUtilsTest.java | 6 +++---
.../test/java/kafka/server/share/SharePartitionManagerTest.java | 4 ++--
core/src/test/java/kafka/server/share/SharePartitionTest.java | 2 +-
.../test/scala/integration/kafka/server/DelayedFetchTest.scala | 3 ++-
.../scala/integration/kafka/server/DelayedRemoteFetchTest.scala | 1 +
core/src/test/scala/other/kafka/StressTestLog.scala | 3 ++-
core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala | 3 ++-
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala | 3 ++-
.../unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala | 3 ++-
.../unit/kafka/coordinator/group/GroupMetadataManagerTest.scala | 3 ++-
.../transaction/TransactionCoordinatorConcurrencyTest.scala | 3 ++-
.../coordinator/transaction/TransactionStateManagerTest.scala | 3 ++-
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala | 3 ++-
core/src/test/scala/unit/kafka/log/LogConcurrencyTest.scala | 3 ++-
core/src/test/scala/unit/kafka/log/LogManagerTest.scala | 3 ++-
core/src/test/scala/unit/kafka/log/LogTestUtils.scala | 3 ++-
core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala | 3 ++-
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala | 3 ++-
.../scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala | 2 +-
.../scala/unit/kafka/server/ReplicaManagerConcurrencyTest.scala | 3 ++-
.../test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala | 3 ++-
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala | 3 ++-
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala | 3 ++-
.../java/org/apache/kafka/server/storage}/log/FetchIsolation.java | 2 +-
.../java/org/apache/kafka/server/storage}/log/FetchParams.java | 2 +-
.../org/apache/kafka/server/storage}/log/FetchPartitionData.java | 2 +-
.../java/org/apache/kafka/server/share/fetch/ShareFetchData.java | 2 +-
.../kafka/storage/internals/log/RemoteStorageFetchInfo.java | 1 +
48 files changed, 82 insertions(+), 52 deletions(-)
rename {storage/src/main/java/org/apache/kafka/storage/internals =>
server-common/src/main/java/org/apache/kafka/server/storage}/log/FetchIsolation.java
(96%)
rename {storage/src/main/java/org/apache/kafka/storage/internals =>
server-common/src/main/java/org/apache/kafka/server/storage}/log/FetchParams.java
(98%)
rename {storage/src/main/java/org/apache/kafka/storage/internals =>
server-common/src/main/java/org/apache/kafka/server/storage}/log/FetchPartitionData.java
(98%)
