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

MINOR: Added evolving annotation to DeleteShareGroupsResult. (#19133) 

* Added `InterfaceStability.Evolving` annotation to`DeleteShareGroupsResult`.
* Fixed some java doc.

Co-authored-by: Andrew Schofield <aschofield@confluent.io>

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>, Andrew Schofield <aschofield@confluent.io>
This commit is contained in:
Sushant Mahajan 2025-03-06 21:47:37 +05:30 committed by GitHub
parent c9804344de
commit b89c819f63
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
View File

@ -1846,6 +1846,7 @@ public interface Admin extends AutoCloseable {
/**
* Delete share groups from the cluster with the default options.
*
* @param groupIds Collection of share group ids which are to be deleted.
* @return The DeleteShareGroupsResult.
*/
default DeleteShareGroupsResult deleteShareGroups(Collection<String> groupIds) {
@ -1855,6 +1856,7 @@ public interface Admin extends AutoCloseable {
/**
* Delete share groups from the cluster.
*
* @param groupIds Collection of share group ids which are to be deleted.
* @param options The options to use when deleting a share group.
* @return The DeleteShareGroupsResult.
*/

4
clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java
View File

@ -18,6 +18,7 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.HashMap;
@ -25,7 +26,10 @@ import java.util.Map;
/**
* The result of the {@link Admin#deleteShareGroups(Collection <String>, DeleteShareGroupsOptions)} call.
* <p></p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteShareGroupsResult {
private final Map<String, KafkaFuture<Void>> futures;