This is an automated email from the ASF dual-hosted git repository. ijuma pushed a change to branch 4.0 in repository https://gitbox.apache.org/repos/asf/kafka.git
from 3a71d593b1b KAFKA-17642: PreVote response handling and ProspectiveState (#18240) new b021b515952 KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870) new a461601ee26 MINOR: Fixing unchecked warning in partition strategy test (#18541) new 146eff7af0d KAFKA-18514: Refactor share module code to server and server-common (#18524) The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: build.gradle | 32 -- checkstyle/import-control-server-common.xml | 9 + checkstyle/import-control-share.xml | 62 ---- .../java/kafka/server/share/DelayedShareFetch.java | 108 ++++--- .../kafka/server/share/DelayedShareFetchTest.java | 357 ++++++++++++++++++++- .../server/share/SharePartitionManagerTest.java | 3 + .../java/kafka/test/api/ShareConsumerTest.java | 2 +- .../server/ShareFetchAcknowledgeRequestTest.scala | 14 +- .../kafka/server/share/SharePartitionKey.java | 0 .../share/persister/DefaultStatePersister.java | 0 .../persister/DeleteShareGroupStateParameters.java | 0 .../persister/DeleteShareGroupStateResult.java | 0 .../share/persister/GroupTopicPartitionData.java | 0 .../InitializeShareGroupStateParameters.java | 0 .../persister/InitializeShareGroupStateResult.java | 0 .../share/persister/NoOpShareStatePersister.java | 0 .../server/share/persister/PartitionAllData.java | 0 .../server/share/persister/PartitionData.java | 0 .../server/share/persister/PartitionErrorData.java | 0 .../server/share/persister/PartitionFactory.java | 0 .../server/share/persister/PartitionIdData.java | 0 .../persister/PartitionIdLeaderEpochData.java | 0 .../server/share/persister/PartitionInfoData.java | 0 .../share/persister/PartitionStateBatchData.java | 0 .../server/share/persister/PartitionStateData.java | 0 .../share/persister/PartitionStateErrorData.java | 0 .../kafka/server/share/persister/Persister.java | 0 .../share/persister/PersisterParameters.java | 0 .../server/share/persister/PersisterResult.java | 0 .../share/persister/PersisterStateBatch.java | 0 .../share/persister/PersisterStateManager.java | 0 .../persister/ReadShareGroupStateParameters.java | 0 .../share/persister/ReadShareGroupStateResult.java | 0 .../ReadShareGroupStateSummaryParameters.java | 0 .../ReadShareGroupStateSummaryResult.java | 0 .../ShareCoordinatorMetadataCacheHelper.java | 0 .../kafka/server/share/persister/TopicData.java | 0 .../persister/WriteShareGroupStateParameters.java | 0 .../persister/WriteShareGroupStateResult.java | 0 .../share/persister/DefaultStatePersisterTest.java | 0 .../share/persister/PersisterStateManagerTest.java | 0 .../kafka/server/share/CachedSharePartition.java | 0 .../share/ErroneousAndValidPartitionData.java | 0 .../acknowledge/ShareAcknowledgementBatch.java | 0 .../kafka/server/share/context/FinalContext.java | 0 .../server/share/context/ShareFetchContext.java | 0 .../server/share/context/ShareSessionContext.java | 0 .../share/fetch/DelayedShareFetchGroupKey.java | 0 .../server/share/fetch/DelayedShareFetchKey.java | 0 .../share/fetch/DelayedShareFetchPartitionKey.java | 0 .../share/fetch/PartitionMaxBytesStrategy.java | 77 +++++ .../server/share/fetch/ShareAcquiredRecords.java | 0 .../kafka/server/share/fetch/ShareFetch.java | 0 .../kafka/server/share/session/LastUsedKey.java | 0 .../kafka/server/share/session/ShareSession.java | 0 .../server/share/session/ShareSessionCache.java | 0 .../server/share/session/ShareSessionKey.java | 0 .../server/share/CachedSharePartitionTest.java | 0 .../share/fetch/DelayedShareFetchKeyTest.java | 0 .../share/fetch/PartitionMaxBytesStrategyTest.java | 89 +++++ .../kafka/server/share/fetch/ShareFetchTest.java | 0 .../share/session/ShareSessionCacheTest.java | 0 .../server/share/session/ShareSessionTest.java | 0 63 files changed, 604 insertions(+), 149 deletions(-) delete mode 100644 checkstyle/import-control-share.xml rename {share => server-common}/src/main/java/org/apache/kafka/server/share/SharePartitionKey.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/DeleteShareGroupStateParameters.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/DeleteShareGroupStateResult.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/GroupTopicPartitionData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/InitializeShareGroupStateParameters.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/InitializeShareGroupStateResult.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/NoOpShareStatePersister.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionAllData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionErrorData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionIdData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionIdLeaderEpochData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionInfoData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionStateBatchData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionStateData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PartitionStateErrorData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/Persister.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PersisterParameters.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PersisterResult.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PersisterStateBatch.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateParameters.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateResult.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateSummaryParameters.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateSummaryResult.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/ShareCoordinatorMetadataCacheHelper.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/TopicData.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/WriteShareGroupStateParameters.java (100%) rename {share => server-common}/src/main/java/org/apache/kafka/server/share/persister/WriteShareGroupStateResult.java (100%) rename {share => server-common}/src/test/java/org/apache/kafka/server/share/persister/DefaultStatePersisterTest.java (100%) rename {share => server-common}/src/test/java/org/apache/kafka/server/share/persister/PersisterStateManagerTest.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/CachedSharePartition.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/ErroneousAndValidPartitionData.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/acknowledge/ShareAcknowledgementBatch.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/context/FinalContext.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/context/ShareFetchContext.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/context/ShareSessionContext.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKey.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchPartitionKey.java (100%) create mode 100644 server/src/main/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategy.java rename {share => server}/src/main/java/org/apache/kafka/server/share/fetch/ShareAcquiredRecords.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/session/LastUsedKey.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/session/ShareSession.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java (100%) rename {share => server}/src/main/java/org/apache/kafka/server/share/session/ShareSessionKey.java (100%) rename {share => server}/src/test/java/org/apache/kafka/server/share/CachedSharePartitionTest.java (100%) rename {share => server}/src/test/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKeyTest.java (100%) create mode 100644 server/src/test/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategyTest.java rename {share => server}/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java (100%) rename {share => server}/src/test/java/org/apache/kafka/server/share/session/ShareSessionCacheTest.java (100%) rename {share => server}/src/test/java/org/apache/kafka/server/share/session/ShareSessionTest.java (100%)