root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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 <jeff.kim@confluent.io>
This commit is contained in:
David Jacot 2024-12-17 20:02:23 +01:00 committed by GitHub
parent 7697d3b826
commit bc5b627ebb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
22 changed files with 0 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ConsumerGroupPartitionAssignor.java
View File

@ -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 {
}

3
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupAssignment.java
View File

@ -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.

2
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupSpec.java
View File

@ -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.

2
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberAssignment.java
View File

@ -17,7 +17,6 @@
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;
@ -25,7 +24,6 @@ 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.

2
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java
View File

@ -17,7 +17,6 @@
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;
@ -25,7 +24,6 @@ import java.util.Set;
/**
* Interface representing the subscription metadata for a group member.
*/
@InterfaceStability.Unstable
public interface MemberSubscription {
/**
* Gets the rack Id if present.

6
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java
View File

@ -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.

5
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscribedTopicDescriber.java
View File

@ -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.

3
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscriptionType.java
View File

@ -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

1
group-coordinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentValue.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataValue.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataValue.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionValue.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberValue.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataKey.json
View File

@ -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",

1
group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataValue.json
View File

@ -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",