This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 67f966f3482 KAFKA-17469: Moved share external interfaces to share
module. (#17262)
67f966f3482 is described below
commit 67f966f34827c8133d16de7740675fc1f9cded5e
Author: Sushant Mahajan <[email protected]>
AuthorDate: Tue Sep 24 21:38:01 2024 +0530
KAFKA-17469: Moved share external interfaces to share module. (#17262)
Reviewers: Apoorv Mittal <[email protected]>, David Arthur
<[email protected]>
---
build.gradle | 1 +
checkstyle/import-control-share-coordinator.xml | 2 +-
checkstyle/import-control-share.xml | 1 +
.../java/kafka/server/share/SharePartition.java | 22 +++++++++++-----------
.../kafka/server/share/SharePartitionManager.java | 2 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 2 +-
.../server/share/SharePartitionManagerTest.java | 4 ++--
.../kafka/server/share/SharePartitionTest.java | 14 +++++++-------
.../share/PersisterOffsetsStateBatch.java | 2 +-
.../coordinator/share/ShareCoordinatorService.java | 2 +-
.../coordinator/share/ShareCoordinatorShard.java | 4 ++--
.../share/ShareCoordinatorShardTest.java | 2 +-
.../share/DeleteShareGroupStateParameters.java | 2 +-
.../server}/share/DeleteShareGroupStateResult.java | 2 +-
.../server}/share/GroupTopicPartitionData.java | 2 +-
.../share/InitializeShareGroupStateParameters.java | 2 +-
.../share/InitializeShareGroupStateResult.java | 2 +-
.../server}/share/NoOpShareStatePersister.java | 4 ++--
.../kafka/server}/share/PartitionAllData.java | 2 +-
.../apache/kafka/server}/share/PartitionData.java | 2 +-
.../kafka/server}/share/PartitionErrorData.java | 2 +-
.../kafka/server}/share/PartitionFactory.java | 2 +-
.../kafka/server}/share/PartitionIdData.java | 2 +-
.../server}/share/PartitionIdLeaderEpochData.java | 2 +-
.../kafka/server}/share/PartitionInfoData.java | 2 +-
.../server}/share/PartitionStateBatchData.java | 2 +-
.../kafka/server}/share/PartitionStateData.java | 2 +-
.../server}/share/PartitionStateErrorData.java | 2 +-
.../org/apache/kafka/server}/share/Persister.java | 2 +-
.../kafka/server}/share/PersisterParameters.java | 2 +-
.../kafka/server}/share/PersisterResult.java | 2 +-
.../kafka/server}/share/PersisterStateBatch.java | 2 +-
.../share/ReadShareGroupStateParameters.java | 2 +-
.../server}/share/ReadShareGroupStateResult.java | 2 +-
.../ReadShareGroupStateSummaryParameters.java | 2 +-
.../share/ReadShareGroupStateSummaryResult.java | 2 +-
.../kafka/server}/share/SharePartitionKey.java | 2 +-
.../org/apache/kafka/server}/share/TopicData.java | 2 +-
.../share/WriteShareGroupStateParameters.java | 2 +-
.../server}/share/WriteShareGroupStateResult.java | 2 +-
40 files changed, 59 insertions(+), 57 deletions(-)
diff --git a/build.gradle b/build.gradle
index a5503c7843a..64b9d488365 100644
--- a/build.gradle
+++ b/build.gradle
@@ -1637,6 +1637,7 @@ project(':share-coordinator') {
implementation project(':metadata')
implementation project(':server')
implementation project(':server-common')
+ implementation project(':share')
implementation libs.slf4jApi
implementation libs.metrics
diff --git a/checkstyle/import-control-share-coordinator.xml
b/checkstyle/import-control-share-coordinator.xml
index c11d79d9943..e31d0f48eed 100644
--- a/checkstyle/import-control-share-coordinator.xml
+++ b/checkstyle/import-control-share-coordinator.xml
@@ -56,7 +56,7 @@
<allow pkg="org.apache.kafka.metadata" />
<allow pkg="org.apache.kafka.server.common" />
<allow pkg="org.apache.kafka.server.config" />
- <allow pkg="org.apache.kafka.server.group.share" />
+ <allow pkg="org.apache.kafka.server.share" />
<allow pkg="org.apache.kafka.server.record" />
<allow pkg="org.apache.kafka.server.util" />
<allow pkg="org.apache.kafka.server.util.timer" />
diff --git a/checkstyle/import-control-share.xml
b/checkstyle/import-control-share.xml
index 531952b9118..f0022d6b318 100644
--- a/checkstyle/import-control-share.xml
+++ b/checkstyle/import-control-share.xml
@@ -33,6 +33,7 @@
<!-- anyone can use public classes -->
<allow pkg="org.apache.kafka.common" exact-match="true" />
<allow pkg="org.apache.kafka.common.utils" />
+ <allow pkg="org.apache.kafka.common.annotation" />
<!-- protocol, records and request/response utilities -->
<allow pkg="org.apache.kafka.common.message" />
diff --git a/core/src/main/java/kafka/server/share/SharePartition.java
b/core/src/main/java/kafka/server/share/SharePartition.java
index 274b934a088..e8519939187 100644
--- a/core/src/main/java/kafka/server/share/SharePartition.java
+++ b/core/src/main/java/kafka/server/share/SharePartition.java
@@ -32,18 +32,18 @@ import
org.apache.kafka.common.message.ShareFetchResponseData.AcquiredRecords;
import org.apache.kafka.common.protocol.Errors;
import org.apache.kafka.common.record.RecordBatch;
import org.apache.kafka.common.utils.Time;
-import org.apache.kafka.server.group.share.GroupTopicPartitionData;
-import org.apache.kafka.server.group.share.PartitionAllData;
-import org.apache.kafka.server.group.share.PartitionErrorData;
-import org.apache.kafka.server.group.share.PartitionFactory;
-import org.apache.kafka.server.group.share.PartitionIdLeaderEpochData;
-import org.apache.kafka.server.group.share.PartitionStateBatchData;
-import org.apache.kafka.server.group.share.Persister;
-import org.apache.kafka.server.group.share.PersisterStateBatch;
-import org.apache.kafka.server.group.share.ReadShareGroupStateParameters;
-import org.apache.kafka.server.group.share.TopicData;
-import org.apache.kafka.server.group.share.WriteShareGroupStateParameters;
+import org.apache.kafka.server.share.GroupTopicPartitionData;
+import org.apache.kafka.server.share.PartitionAllData;
+import org.apache.kafka.server.share.PartitionErrorData;
+import org.apache.kafka.server.share.PartitionFactory;
+import org.apache.kafka.server.share.PartitionIdLeaderEpochData;
+import org.apache.kafka.server.share.PartitionStateBatchData;
+import org.apache.kafka.server.share.Persister;
+import org.apache.kafka.server.share.PersisterStateBatch;
+import org.apache.kafka.server.share.ReadShareGroupStateParameters;
import org.apache.kafka.server.share.ShareAcknowledgementBatch;
+import org.apache.kafka.server.share.TopicData;
+import org.apache.kafka.server.share.WriteShareGroupStateParameters;
import org.apache.kafka.server.util.timer.Timer;
import org.apache.kafka.server.util.timer.TimerTask;
import org.apache.kafka.storage.internals.log.FetchPartitionData;
diff --git a/core/src/main/java/kafka/server/share/SharePartitionManager.java
b/core/src/main/java/kafka/server/share/SharePartitionManager.java
index 2665d7dd8b4..3679f1c719a 100644
--- a/core/src/main/java/kafka/server/share/SharePartitionManager.java
+++ b/core/src/main/java/kafka/server/share/SharePartitionManager.java
@@ -38,8 +38,8 @@ import org.apache.kafka.common.requests.ShareFetchRequest;
import org.apache.kafka.common.requests.ShareRequestMetadata;
import org.apache.kafka.common.utils.ImplicitLinkedHashCollection;
import org.apache.kafka.common.utils.Time;
-import org.apache.kafka.server.group.share.Persister;
import org.apache.kafka.server.share.CachedSharePartition;
+import org.apache.kafka.server.share.Persister;
import org.apache.kafka.server.share.ShareAcknowledgementBatch;
import org.apache.kafka.server.share.context.FinalContext;
import org.apache.kafka.server.share.context.ShareFetchContext;
diff --git a/core/src/main/scala/kafka/server/BrokerServer.scala
b/core/src/main/scala/kafka/server/BrokerServer.scala
index 34ec3398b8e..f59b6bcae39 100644
--- a/core/src/main/scala/kafka/server/BrokerServer.scala
+++ b/core/src/main/scala/kafka/server/BrokerServer.scala
@@ -47,7 +47,7 @@ import org.apache.kafka.server.{AssignmentsManager,
ClientMetricsManager, NodeTo
import org.apache.kafka.server.authorizer.Authorizer
import org.apache.kafka.server.common.{ApiMessageAndVersion,
DirectoryEventHandler, TopicIdPartition}
import org.apache.kafka.server.config.ConfigType
-import org.apache.kafka.server.group.share.{NoOpShareStatePersister, Persister}
+import org.apache.kafka.server.share.{NoOpShareStatePersister, Persister}
import org.apache.kafka.server.log.remote.storage.RemoteLogManagerConfig
import org.apache.kafka.server.metrics.{ClientMetricsReceiverPlugin,
KafkaYammerMetrics}
import org.apache.kafka.server.network.{EndpointReadyFutures,
KafkaAuthorizerServerInfo}
diff --git
a/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
b/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
index 05c6b6c7264..861233cda9c 100644
--- a/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
+++ b/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
@@ -49,10 +49,10 @@ import
org.apache.kafka.common.requests.ShareRequestMetadata;
import org.apache.kafka.common.utils.ImplicitLinkedHashCollection;
import org.apache.kafka.common.utils.MockTime;
import org.apache.kafka.common.utils.Time;
-import org.apache.kafka.server.group.share.NoOpShareStatePersister;
-import org.apache.kafka.server.group.share.Persister;
import org.apache.kafka.server.share.CachedSharePartition;
import org.apache.kafka.server.share.ErroneousAndValidPartitionData;
+import org.apache.kafka.server.share.NoOpShareStatePersister;
+import org.apache.kafka.server.share.Persister;
import org.apache.kafka.server.share.ShareAcknowledgementBatch;
import org.apache.kafka.server.share.context.FinalContext;
import org.apache.kafka.server.share.context.ShareFetchContext;
diff --git a/core/src/test/java/kafka/server/share/SharePartitionTest.java
b/core/src/test/java/kafka/server/share/SharePartitionTest.java
index 38667fefbdc..4d821db3dc6 100644
--- a/core/src/test/java/kafka/server/share/SharePartitionTest.java
+++ b/core/src/test/java/kafka/server/share/SharePartitionTest.java
@@ -37,14 +37,14 @@ import org.apache.kafka.common.record.MemoryRecordsBuilder;
import org.apache.kafka.common.record.TimestampType;
import org.apache.kafka.common.utils.MockTime;
import org.apache.kafka.common.utils.Time;
-import org.apache.kafka.server.group.share.NoOpShareStatePersister;
-import org.apache.kafka.server.group.share.PartitionFactory;
-import org.apache.kafka.server.group.share.Persister;
-import org.apache.kafka.server.group.share.PersisterStateBatch;
-import org.apache.kafka.server.group.share.ReadShareGroupStateResult;
-import org.apache.kafka.server.group.share.TopicData;
-import org.apache.kafka.server.group.share.WriteShareGroupStateResult;
+import org.apache.kafka.server.share.NoOpShareStatePersister;
+import org.apache.kafka.server.share.PartitionFactory;
+import org.apache.kafka.server.share.Persister;
+import org.apache.kafka.server.share.PersisterStateBatch;
+import org.apache.kafka.server.share.ReadShareGroupStateResult;
import org.apache.kafka.server.share.ShareAcknowledgementBatch;
+import org.apache.kafka.server.share.TopicData;
+import org.apache.kafka.server.share.WriteShareGroupStateResult;
import org.apache.kafka.server.util.FutureUtils;
import org.apache.kafka.server.util.timer.SystemTimer;
import org.apache.kafka.server.util.timer.SystemTimerReaper;
diff --git
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/PersisterOffsetsStateBatch.java
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/PersisterOffsetsStateBatch.java
index 138b79d1733..ff9feaf1918 100644
---
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/PersisterOffsetsStateBatch.java
+++
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/PersisterOffsetsStateBatch.java
@@ -19,7 +19,7 @@ package org.apache.kafka.coordinator.share;
import org.apache.kafka.common.message.WriteShareGroupStateRequestData;
import org.apache.kafka.coordinator.share.generated.ShareUpdateValue;
-import org.apache.kafka.server.group.share.PersisterStateBatch;
+import org.apache.kafka.server.share.PersisterStateBatch;
import java.util.Objects;
diff --git
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java
index 67dc56b61ba..0242ee3f54e 100644
---
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java
+++
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java
@@ -43,8 +43,8 @@ import
org.apache.kafka.coordinator.common.runtime.MultiThreadedEventProcessor;
import org.apache.kafka.coordinator.common.runtime.PartitionWriter;
import org.apache.kafka.coordinator.share.metrics.ShareCoordinatorMetrics;
import org.apache.kafka.server.config.ShareCoordinatorConfig;
-import org.apache.kafka.server.group.share.SharePartitionKey;
import org.apache.kafka.server.record.BrokerCompressionType;
+import org.apache.kafka.server.share.SharePartitionKey;
import org.apache.kafka.server.util.timer.Timer;
import org.slf4j.Logger;
diff --git
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java
index 3eafe7da3d2..a5bf6192024 100644
---
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java
+++
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java
@@ -47,8 +47,8 @@ import org.apache.kafka.image.MetadataDelta;
import org.apache.kafka.image.MetadataImage;
import org.apache.kafka.server.common.ApiMessageAndVersion;
import org.apache.kafka.server.config.ShareCoordinatorConfig;
-import org.apache.kafka.server.group.share.PartitionFactory;
-import org.apache.kafka.server.group.share.SharePartitionKey;
+import org.apache.kafka.server.share.PartitionFactory;
+import org.apache.kafka.server.share.SharePartitionKey;
import org.apache.kafka.timeline.SnapshotRegistry;
import org.apache.kafka.timeline.TimelineHashMap;
diff --git
a/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorShardTest.java
b/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorShardTest.java
index ea51a43084a..50c0f5de3e2 100644
---
a/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorShardTest.java
+++
b/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorShardTest.java
@@ -40,7 +40,7 @@ import org.apache.kafka.image.TopicImage;
import org.apache.kafka.metadata.PartitionRegistration;
import org.apache.kafka.server.common.ApiMessageAndVersion;
import org.apache.kafka.server.config.ShareCoordinatorConfig;
-import org.apache.kafka.server.group.share.SharePartitionKey;
+import org.apache.kafka.server.share.SharePartitionKey;
import org.apache.kafka.timeline.SnapshotRegistry;
import org.junit.jupiter.api.Test;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/DeleteShareGroupStateParameters.java
b/share/src/main/java/org/apache/kafka/server/share/DeleteShareGroupStateParameters.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/DeleteShareGroupStateParameters.java
rename to
share/src/main/java/org/apache/kafka/server/share/DeleteShareGroupStateParameters.java
index 7b57c18f938..59e5886f101 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/DeleteShareGroupStateParameters.java
+++
b/share/src/main/java/org/apache/kafka/server/share/DeleteShareGroupStateParameters.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.DeleteShareGroupStateRequestData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/DeleteShareGroupStateResult.java
b/share/src/main/java/org/apache/kafka/server/share/DeleteShareGroupStateResult.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/DeleteShareGroupStateResult.java
rename to
share/src/main/java/org/apache/kafka/server/share/DeleteShareGroupStateResult.java
index f24f5791484..264e203800f 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/DeleteShareGroupStateResult.java
+++
b/share/src/main/java/org/apache/kafka/server/share/DeleteShareGroupStateResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.DeleteShareGroupStateResponseData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/GroupTopicPartitionData.java
b/share/src/main/java/org/apache/kafka/server/share/GroupTopicPartitionData.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/GroupTopicPartitionData.java
rename to
share/src/main/java/org/apache/kafka/server/share/GroupTopicPartitionData.java
index e92ae5c73eb..f0e1809ac46 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/GroupTopicPartitionData.java
+++
b/share/src/main/java/org/apache/kafka/server/share/GroupTopicPartitionData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import java.util.List;
import java.util.Objects;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/InitializeShareGroupStateParameters.java
b/share/src/main/java/org/apache/kafka/server/share/InitializeShareGroupStateParameters.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/InitializeShareGroupStateParameters.java
rename to
share/src/main/java/org/apache/kafka/server/share/InitializeShareGroupStateParameters.java
index 3dfa4fce932..a1e4cc663e2 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/InitializeShareGroupStateParameters.java
+++
b/share/src/main/java/org/apache/kafka/server/share/InitializeShareGroupStateParameters.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.InitializeShareGroupStateRequestData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/InitializeShareGroupStateResult.java
b/share/src/main/java/org/apache/kafka/server/share/InitializeShareGroupStateResult.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/InitializeShareGroupStateResult.java
rename to
share/src/main/java/org/apache/kafka/server/share/InitializeShareGroupStateResult.java
index fe61810ac57..744679736ff 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/InitializeShareGroupStateResult.java
+++
b/share/src/main/java/org/apache/kafka/server/share/InitializeShareGroupStateResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.InitializeShareGroupStateResponseData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/NoOpShareStatePersister.java
b/share/src/main/java/org/apache/kafka/server/share/NoOpShareStatePersister.java
similarity index 99%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/NoOpShareStatePersister.java
rename to
share/src/main/java/org/apache/kafka/server/share/NoOpShareStatePersister.java
index 9b9a984de17..900b25efdd0 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/NoOpShareStatePersister.java
+++
b/share/src/main/java/org/apache/kafka/server/share/NoOpShareStatePersister.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import java.util.ArrayList;
import java.util.Collections;
@@ -111,4 +111,4 @@ public class NoOpShareStatePersister implements Persister {
public void stop() {
//noop
}
-}
\ No newline at end of file
+}
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionAllData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionAllData.java
similarity index 96%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionAllData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionAllData.java
index cfe6e383284..2a9f55dd5f6 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionAllData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionAllData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import java.util.List;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionData.java
similarity index 99%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionData.java
rename to share/src/main/java/org/apache/kafka/server/share/PartitionData.java
index da7f385597e..e424619d8eb 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import java.util.List;
import java.util.Objects;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionErrorData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionErrorData.java
similarity index 96%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionErrorData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionErrorData.java
index 8e6804dac8b..4fb9f83fc52 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionErrorData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionErrorData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* This interface is implemented by classes used to contain the data for a
partition with error data
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionFactory.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionFactory.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionFactory.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionFactory.java
index f17873aacbe..5adf87c3c27 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionFactory.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.protocol.Errors;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionIdData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionIdData.java
similarity index 95%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionIdData.java
rename to share/src/main/java/org/apache/kafka/server/share/PartitionIdData.java
index 3ba3edd93d0..feb288bb13c 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionIdData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionIdData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* This interface is implemented by classes used to contain the data for a
partition with its partition index
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionIdLeaderEpochData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionIdLeaderEpochData.java
similarity index 95%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionIdLeaderEpochData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionIdLeaderEpochData.java
index 5d44d5448a6..aa9da7428e6 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionIdLeaderEpochData.java
+++
b/share/src/main/java/org/apache/kafka/server/share/PartitionIdLeaderEpochData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* This interface is implemented by classes used to contain the data for a
partition with its leader epoch
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionInfoData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionInfoData.java
similarity index 95%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionInfoData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionInfoData.java
index 3c430a4d6ec..3c4ef895368 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionInfoData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionInfoData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* This interface is implemented by classes used to contain the data for a
partition in the
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateBatchData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionStateBatchData.java
similarity index 96%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateBatchData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionStateBatchData.java
index 7722bd90266..dfd06cb5dd8 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateBatchData.java
+++
b/share/src/main/java/org/apache/kafka/server/share/PartitionStateBatchData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import java.util.List;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionStateData.java
similarity index 96%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionStateData.java
index 1ceb0a5904b..f1690ff4d32 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PartitionStateData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* This interface is implemented by classes used to contain the data for a
partition with the state epoch and
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateErrorData.java
b/share/src/main/java/org/apache/kafka/server/share/PartitionStateErrorData.java
similarity index 96%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateErrorData.java
rename to
share/src/main/java/org/apache/kafka/server/share/PartitionStateErrorData.java
index 74cce273d1e..af238751392 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PartitionStateErrorData.java
+++
b/share/src/main/java/org/apache/kafka/server/share/PartitionStateErrorData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* This interface is implemented by classes used to contain the data for a
partition with state and error data
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/Persister.java
b/share/src/main/java/org/apache/kafka/server/share/Persister.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/Persister.java
rename to share/src/main/java/org/apache/kafka/server/share/Persister.java
index 5f4de38a9fb..2dc53e1c92c 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/Persister.java
+++ b/share/src/main/java/org/apache/kafka/server/share/Persister.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.annotation.InterfaceStability;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PersisterParameters.java
b/share/src/main/java/org/apache/kafka/server/share/PersisterParameters.java
similarity index 95%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PersisterParameters.java
rename to
share/src/main/java/org/apache/kafka/server/share/PersisterParameters.java
index b8e1bd0ebc5..f3c481570d2 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PersisterParameters.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PersisterParameters.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* Marker interface for parameter classes related to the {@link Persister}
result classes.
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PersisterResult.java
b/share/src/main/java/org/apache/kafka/server/share/PersisterResult.java
similarity index 95%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PersisterResult.java
rename to share/src/main/java/org/apache/kafka/server/share/PersisterResult.java
index 7cb944e2ff0..94eb481d2ac 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PersisterResult.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PersisterResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
/**
* Marker interface for result classes related to the {@link Persister} result
classes.
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/PersisterStateBatch.java
b/share/src/main/java/org/apache/kafka/server/share/PersisterStateBatch.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/PersisterStateBatch.java
rename to
share/src/main/java/org/apache/kafka/server/share/PersisterStateBatch.java
index f6ff8fdcb38..5201d75545a 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/PersisterStateBatch.java
+++ b/share/src/main/java/org/apache/kafka/server/share/PersisterStateBatch.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.ReadShareGroupStateResponseData;
import org.apache.kafka.common.message.WriteShareGroupStateRequestData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateParameters.java
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateParameters.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateParameters.java
rename to
share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateParameters.java
index 1ba456a4be7..225de97de6a 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateParameters.java
+++
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateParameters.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.ReadShareGroupStateRequestData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateResult.java
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateResult.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateResult.java
rename to
share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateResult.java
index 092e5e3d37b..ce80d60d265 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateResult.java
+++
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.ReadShareGroupStateResponseData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateSummaryParameters.java
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateSummaryParameters.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateSummaryParameters.java
rename to
share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateSummaryParameters.java
index ca27ec9664b..728b176b77d 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateSummaryParameters.java
+++
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateSummaryParameters.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.ReadShareGroupStateSummaryRequestData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateSummaryResult.java
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateSummaryResult.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateSummaryResult.java
rename to
share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateSummaryResult.java
index 62de812e5d5..4f56fe2cfab 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/ReadShareGroupStateSummaryResult.java
+++
b/share/src/main/java/org/apache/kafka/server/share/ReadShareGroupStateSummaryResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.ReadShareGroupStateSummaryResponseData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/SharePartitionKey.java
b/share/src/main/java/org/apache/kafka/server/share/SharePartitionKey.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/SharePartitionKey.java
rename to
share/src/main/java/org/apache/kafka/server/share/SharePartitionKey.java
index 27419dc89e0..6e56edbf3bb 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/SharePartitionKey.java
+++ b/share/src/main/java/org/apache/kafka/server/share/SharePartitionKey.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.TopicIdPartition;
import org.apache.kafka.common.Uuid;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/TopicData.java
b/share/src/main/java/org/apache/kafka/server/share/TopicData.java
similarity index 97%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/TopicData.java
rename to share/src/main/java/org/apache/kafka/server/share/TopicData.java
index 321d2465f62..4d31d9f7265 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/TopicData.java
+++ b/share/src/main/java/org/apache/kafka/server/share/TopicData.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.Uuid;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/WriteShareGroupStateParameters.java
b/share/src/main/java/org/apache/kafka/server/share/WriteShareGroupStateParameters.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/WriteShareGroupStateParameters.java
rename to
share/src/main/java/org/apache/kafka/server/share/WriteShareGroupStateParameters.java
index 7ba789d3084..7b4bbbbc770 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/WriteShareGroupStateParameters.java
+++
b/share/src/main/java/org/apache/kafka/server/share/WriteShareGroupStateParameters.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.WriteShareGroupStateRequestData;
diff --git
a/server-common/src/main/java/org/apache/kafka/server/group/share/WriteShareGroupStateResult.java
b/share/src/main/java/org/apache/kafka/server/share/WriteShareGroupStateResult.java
similarity index 98%
rename from
server-common/src/main/java/org/apache/kafka/server/group/share/WriteShareGroupStateResult.java
rename to
share/src/main/java/org/apache/kafka/server/share/WriteShareGroupStateResult.java
index 0d925cb971b..b96ec217b6d 100644
---
a/server-common/src/main/java/org/apache/kafka/server/group/share/WriteShareGroupStateResult.java
+++
b/share/src/main/java/org/apache/kafka/server/share/WriteShareGroupStateResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.kafka.server.group.share;
+package org.apache.kafka.server.share;
import org.apache.kafka.common.message.WriteShareGroupStateResponseData;
