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%)

Reply via email to