MINOR: Mark KIP-848's public apis as stable (#18235)

KIP-848 will be release as GA in Apache Kafka 4.0. Hence we need to mark all the related public apis as stable. Reviewers: Jeff Kim <[email protected]>
apache · Dec 17, 2024 · bc5b627 · bc5b627
1 parent 7697d3b
commit bc5b627
Show file tree

Hide file tree

Showing 22 changed files with 0 additions and 43 deletions.
diff --git a/.../java/org/apache/kafka/coordinator/group/api/assignor/ConsumerGroupPartitionAssignor.java b/.../java/org/apache/kafka/coordinator/group/api/assignor/ConsumerGroupPartitionAssignor.java
@@ -16,14 +16,8 @@
  */
 package org.apache.kafka.coordinator.group.api.assignor;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 /**
  * Server-side partition assignor for consumer groups used by the GroupCoordinator.
- *
- * The new consumer group protocol is in preview so this interface is considered
- * unstable until Apache Kafka 4.0.
  */
-@InterfaceStability.Unstable
 public interface ConsumerGroupPartitionAssignor extends PartitionAssignor {
 }
diff --git a/...or-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupAssignment.java b/...or-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupAssignment.java
@@ -16,15 +16,12 @@
  */
 package org.apache.kafka.coordinator.group.api.assignor;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 import java.util.Map;
 import java.util.Objects;
 
 /**
  * The partition assignment for a consumer group.
  */
-@InterfaceStability.Unstable
 public class GroupAssignment {
     /**
      * The member assignments keyed by member id.

diff --git a/...rdinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupSpec.java b/...rdinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupSpec.java
@@ -17,14 +17,12 @@
 package org.apache.kafka.coordinator.group.api.assignor;
 
 import org.apache.kafka.common.Uuid;
-import org.apache.kafka.common.annotation.InterfaceStability;
 
 import java.util.Collection;
 
 /**
  * The group metadata specifications required to compute the target assignment.
  */
-@InterfaceStability.Unstable
 public interface GroupSpec {
     /**
      * @return All the member Ids of the consumer group.

diff --git a/...r-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberAssignment.java b/...r-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberAssignment.java
@@ -17,15 +17,13 @@
 package org.apache.kafka.coordinator.group.api.assignor;
 
 import org.apache.kafka.common.Uuid;
-import org.apache.kafka.common.annotation.InterfaceStability;
 
 import java.util.Map;
 import java.util.Set;
 
 /**
  * The partition assignment for a consumer group member.
  */
-@InterfaceStability.Unstable
 public interface MemberAssignment {
     /**
      * @return The assigned partitions keyed by topic Ids.

diff --git a/...api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java b/...api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java
@@ -17,15 +17,13 @@
 package org.apache.kafka.coordinator.group.api.assignor;
 
 import org.apache.kafka.common.Uuid;
-import org.apache.kafka.common.annotation.InterfaceStability;
 
 import java.util.Optional;
 import java.util.Set;
 
 /**
  * Interface representing the subscription metadata for a group member.
  */
-@InterfaceStability.Unstable
 public interface MemberSubscription {
     /**
      * Gets the rack Id if present.

diff --git a/...-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java b/...-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java
@@ -16,15 +16,9 @@
  */
 package org.apache.kafka.coordinator.group.api.assignor;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 /**
  * Server-side partition assignor used by the GroupCoordinator.
- *
- * The new consumer group protocol is in preview so this interface is considered
- * unstable until Apache Kafka 4.0.
  */
-@InterfaceStability.Unstable
 public interface PartitionAssignor {
     /**
      * Unique name for this assignor.

diff --git a/...c/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscribedTopicDescriber.java b/...c/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscribedTopicDescriber.java
@@ -17,18 +17,13 @@
 package org.apache.kafka.coordinator.group.api.assignor;
 
 import org.apache.kafka.common.Uuid;
-import org.apache.kafka.common.annotation.InterfaceStability;
 
 import java.util.Set;
 
 /**
  * The subscribed topic describer is used by the {@link PartitionAssignor}
  * to obtain topic and partition metadata of the subscribed topics.
- *
- * The interface is kept in an internal module until KIP-848 is fully
- * implemented and ready to be released.
  */
-@InterfaceStability.Unstable
 public interface SubscribedTopicDescriber {
     /**
      * The number of partitions for the given topic Id.

diff --git a/...r-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscriptionType.java b/...r-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscriptionType.java
@@ -16,12 +16,9 @@
  */
 package org.apache.kafka.coordinator.group.api.assignor;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 /**
  * The subscription type followed by a consumer group.
  */
-@InterfaceStability.Unstable
 public enum SubscriptionType {
     /**
      * A homogeneous subscription type means that all the members

diff --git a/...oordinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentKey.json b/...oordinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupCurrentMemberAssignmentKey",

diff --git a/...rdinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentValue.json b/...rdinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupCurrentMemberAssignmentValue",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataKey.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupMemberMetadataKey",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataValue.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupMemberMetadataValue",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataKey.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupMetadataKey",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataValue.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupMetadataValue",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataKey.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupPartitionMetadataKey",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupPartitionMetadataValue",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionKey.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupRegularExpressionKey",

diff --git a/group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionValue.json b/group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupRegularExpressionValue",

diff --git a/...coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberKey.json b/...coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupTargetAssignmentMemberKey",

diff --git a/...ordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberValue.json b/...ordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupTargetAssignmentMemberValue",

diff --git a/...ordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataKey.json b/...ordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataKey.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupTargetAssignmentMetadataKey",

diff --git a/...dinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataValue.json b/...dinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataValue.json
@@ -13,7 +13,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// KIP-848 is in development. This schema is subject to non-backwards-compatible changes.
 {
   "type": "data",
   "name": "ConsumerGroupTargetAssignmentMetadataValue",