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

KAFKA-18864:remove the Evolving tag from stable public interfaces (#19036) 

The purpose of this PR is to remove the `@InterfaceStability.Evolving` from classes that were created over a year ago.

Reviewers: Jun Rao <junrao@gmail.com>
This commit is contained in:
Xuan-Zhang Gong 2025-03-01 05:24:24 +08:00 committed by GitHub
parent 8cf969e00a
commit 45f932819e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
144 changed files with 7 additions and 565 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionOptions.java
View File

@ -16,9 +16,6 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
@InterfaceStability.Evolving
public class AbortTransactionOptions extends AbstractOptions<AbortTransactionOptions> {
@Override

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

@ -18,16 +18,12 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* The result of {@link Admin#abortTransaction(AbortTransactionSpec, AbortTransactionOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class AbortTransactionResult {
private final Map<TopicPartition, KafkaFuture<Void>> futures;

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

@ -17,11 +17,9 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
@InterfaceStability.Evolving
public class AbortTransactionSpec {
private final TopicPartition topicPartition;
private final long producerId;

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

@ -120,12 +120,7 @@ import java.util.Set;
* The minimum broker version required is 0.10.0.0. Methods with stricter requirements will specify the minimum broker
* version required.
* <p>
* This client was introduced in 0.11.0.0 and the API is still evolving. We will try to evolve the API in a compatible
* manner, but we reserve the right to make breaking changes in minor releases, if necessary. We will update the
* {@code InterfaceStability} annotation and this notice once the API is considered stable.
* <p>
*/
@InterfaceStability.Evolving
public interface Admin extends AutoCloseable {
/**

5
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#alterClientQuotas(Collection, AlterClientQuotasOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class AlterClientQuotasOptions extends AbstractOptions<AlterClientQuotasOptions> {
private boolean validateOnly = false;

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

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

7
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java
View File

@ -17,8 +17,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Arrays;
import java.util.Collections;
import java.util.Map;
@ -27,11 +25,8 @@ import java.util.function.Function;
import java.util.stream.Collectors;
/**
* A class representing a alter configuration entry containing name, value and operation type.
*
* The API of this class is evolving, see {@link Admin} for details.
* A class representing an alter configuration entry containing name, value and operation type.
*/
@InterfaceStability.Evolving
public class AlterConfigOp {
public enum OpType {

5
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link Admin#incrementalAlterConfigs(Map)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class AlterConfigsOptions extends AbstractOptions<AlterConfigsOptions> {
private boolean validateOnly = false;

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

@ -18,17 +18,13 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.config.ConfigResource;
import java.util.Map;
/**
* The result of the {@link Admin#incrementalAlterConfigs(Map, AlterConfigsOptions)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class AlterConfigsResult {
private final Map<ConfigResource, KafkaFuture<Void>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java
View File

@ -16,15 +16,10 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for the {@link AdminClient#alterConsumerGroupOffsets(String, Map, AlterConsumerGroupOffsetsOptions)} call.
*
* The API of this class is evolving, see {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class AlterConsumerGroupOffsetsOptions extends AbstractOptions<AlterConsumerGroupOffsetsOptions> {
}

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

@ -18,7 +18,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import org.apache.kafka.common.protocol.Errors;
@ -28,10 +27,7 @@ import java.util.stream.Collectors;
/**
* The result of the {@link AdminClient#alterConsumerGroupOffsets(String, Map)} call.
*
* The API of this class is evolving, see {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class AlterConsumerGroupOffsetsResult {
private final KafkaFuture<Map<TopicPartition, Errors>> future;

5
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java
View File

@ -17,15 +17,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link AdminClient#alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions)}
*
* The API of this class is evolving. See {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class AlterPartitionReassignmentsOptions extends AbstractOptions<AlterPartitionReassignmentsOptions> {
}

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

@ -19,16 +19,12 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* The result of {@link AdminClient#alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions)}.
*
* The API of this class is evolving. See {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class AlterPartitionReassignmentsResult {
private final Map<TopicPartition, KafkaFuture<Void>> futures;

3
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java
View File

@ -17,14 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link Admin#alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions)}.
*/
@InterfaceStability.Evolving
public class AlterReplicaLogDirsOptions extends AbstractOptions<AlterReplicaLogDirsOptions> {
}

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

@ -18,7 +18,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartitionReplica;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.errors.ClusterAuthorizationException;
import org.apache.kafka.common.errors.InvalidTopicException;
import org.apache.kafka.common.errors.KafkaStorageException;
@ -36,7 +35,6 @@ import java.util.concurrent.ExecutionException;
* To retrieve the detailed result per specified {@link TopicPartitionReplica}, use {@link #values()}. To retrieve the
* overall result only, use {@link #all()}.
*/
@InterfaceStability.Evolving
public class AlterReplicaLogDirsResult {
private final Map<TopicPartitionReplica, KafkaFuture<Void>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java
View File

@ -17,15 +17,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.List;
/**
* Options for {@link AdminClient#alterUserScramCredentials(List, AlterUserScramCredentialsOptions)}
*
* The API of this class is evolving. See {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class AlterUserScramCredentialsOptions extends AbstractOptions<AlterUserScramCredentialsOptions> {
}

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

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

3
clients/src/main/java/org/apache/kafka/clients/admin/ClientMetricsResourceListing.java
View File

@ -16,11 +16,8 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
@InterfaceStability.Evolving
public class ClientMetricsResourceListing {
private final String name;

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

@ -17,8 +17,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
@ -27,9 +25,7 @@ import java.util.Map;
/**
* A configuration object containing the configuration entries for a resource.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class Config {
private final Map<String, ConfigEntry> entries = new HashMap<>();

5
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
View File

@ -17,18 +17,13 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collections;
import java.util.List;
import java.util.Objects;
/**
* A class representing a configuration entry containing name, value and additional metadata.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ConfigEntry {
private final String name;

5
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#createAcls(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreateAclsOptions extends AbstractOptions<CreateAclsOptions> {
/**

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

@ -19,17 +19,13 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.acl.AclBinding;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Map;
/**
* The result of the {@link Admin#createAcls(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreateAclsResult {
private final Map<AclBinding, KafkaFuture<Void>> futures;

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

@ -17,7 +17,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.security.auth.KafkaPrincipal;
import java.util.LinkedList;
@ -26,10 +25,7 @@ import java.util.Optional;
/**
* Options for {@link Admin#createDelegationToken(CreateDelegationTokenOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreateDelegationTokenOptions extends AbstractOptions<CreateDelegationTokenOptions> {
private long maxLifetimeMs = -1;
private List<KafkaPrincipal> renewers = new LinkedList<>();

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

@ -18,15 +18,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.security.token.delegation.DelegationToken;
/**
* The result of the {@link KafkaAdminClient#createDelegationToken(CreateDelegationTokenOptions)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreateDelegationTokenResult {
private final KafkaFuture<DelegationToken> delegationToken;

5
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link Admin#createPartitions(Map)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreatePartitionsOptions extends AbstractOptions<CreatePartitionsOptions> {
private boolean validateOnly = false;

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

@ -18,16 +18,12 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* The result of the {@link Admin#createPartitions(Map)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreatePartitionsResult {
private final Map<String, KafkaFuture<Void>> values;

5
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#createTopics(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreateTopicsOptions extends AbstractOptions<CreateTopicsOptions> {
private boolean validateOnly = false;

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

@ -18,7 +18,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.Uuid;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.errors.ApiException;
import java.util.Collection;
@ -27,10 +26,7 @@ import java.util.stream.Collectors;
/**
* The result of {@link Admin#createTopics(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class CreateTopicsResult {
static final int UNKNOWN = -1;

5
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for the {@link Admin#deleteAcls(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteAclsOptions extends AbstractOptions<DeleteAclsOptions> {
/**

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

@ -21,7 +21,6 @@ import org.apache.kafka.common.KafkaException;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.acl.AclBinding;
import org.apache.kafka.common.acl.AclBindingFilter;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.errors.ApiException;
import java.util.ArrayList;
@ -31,10 +30,7 @@ import java.util.Map;
/**
* The result of the {@link Admin#deleteAcls(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteAclsResult {
/**

5
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java
View File

@ -16,16 +16,11 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Set;
/**
* Options for the {@link Admin#deleteConsumerGroupOffsets(String, Set)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteConsumerGroupOffsetsOptions extends AbstractOptions<DeleteConsumerGroupOffsetsOptions> {
}

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

@ -18,7 +18,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import org.apache.kafka.common.protocol.Errors;
@ -27,10 +26,7 @@ import java.util.Set;
/**
* The result of the {@link Admin#deleteConsumerGroupOffsets(String, Set)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteConsumerGroupOffsetsResult {
private final KafkaFuture<Map<TopicPartition, Errors>> future;
private final Set<TopicPartition> partitions;

5
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java
View File

@ -16,16 +16,11 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for the {@link Admin#deleteConsumerGroups(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteConsumerGroupsOptions extends AbstractOptions<DeleteConsumerGroupsOptions> {
}

5
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link Admin#deleteRecords(Map, DeleteRecordsOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteRecordsOptions extends AbstractOptions<DeleteRecordsOptions> {
}

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

@ -19,16 +19,12 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* The result of the {@link Admin#deleteRecords(Map)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteRecordsResult {
private final Map<TopicPartition, KafkaFuture<DeletedRecords>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#deleteTopics(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteTopicsOptions extends AbstractOptions<DeleteTopicsOptions> {
private boolean retryOnQuotaViolation = true;

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

@ -20,17 +20,13 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicCollection;
import org.apache.kafka.common.Uuid;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Map;
/**
* The result of the {@link Admin#deleteTopics(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DeleteTopicsResult {
private final Map<Uuid, KafkaFuture<Void>> topicIdFutures;
private final Map<String, KafkaFuture<Void>> nameFutures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java
View File

@ -17,14 +17,9 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Represents information about deleted records
*
* The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
*/
@InterfaceStability.Evolving
public class DeletedRecords {
private final long lowWatermark;

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

@ -18,14 +18,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.acl.AclBindingFilter;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#describeAcls(AclBindingFilter)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeAclsOptions extends AbstractOptions<DescribeAclsOptions> {
/**

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

@ -20,16 +20,12 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.acl.AclBinding;
import org.apache.kafka.common.acl.AclBindingFilter;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* The result of the {@link KafkaAdminClient#describeAcls(AclBindingFilter)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeAclsResult {
private final KafkaFuture<Collection<AclBinding>> future;

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

@ -17,14 +17,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.quota.ClientQuotaFilter;
/**
* Options for {@link Admin#describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeClientQuotasOptions extends AbstractOptions<DescribeClientQuotasOptions> {
}

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

@ -18,7 +18,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.quota.ClientQuotaEntity;
import org.apache.kafka.common.quota.ClientQuotaFilter;
@ -26,10 +25,7 @@ import java.util.Map;
/**
* The result of the {@link Admin#describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeClientQuotasResult {
private final KafkaFuture<Map<ClientQuotaEntity, Map<String, Double>>> entities;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java
View File

@ -17,14 +17,9 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#describeCluster()}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeClusterOptions extends AbstractOptions<DescribeClusterOptions> {
private boolean includeAuthorizedOperations;

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

@ -20,17 +20,13 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.Node;
import org.apache.kafka.common.acl.AclOperation;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Set;
/**
* The result of the {@link KafkaAdminClient#describeCluster()} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeClusterResult {
private final KafkaFuture<Collection<Node>> nodes;
private final KafkaFuture<Node> controller;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#describeConfigs(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeConfigsOptions extends AbstractOptions<DescribeConfigsOptions> {
private boolean includeSynonyms = false;

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

@ -18,7 +18,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.config.ConfigResource;
import java.util.Collection;
@ -28,10 +27,7 @@ import java.util.concurrent.ExecutionException;
/**
* The result of the {@link KafkaAdminClient#describeConfigs(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeConfigsResult {
private final Map<ConfigResource, KafkaFuture<Config>> futures;

6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsOptions.java
View File

@ -17,16 +17,12 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)}.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeConsumerGroupsOptions extends AbstractOptions<DescribeConsumerGroupsOptions> {
private boolean includeAuthorizedOperations;
@ -38,4 +34,4 @@ public class DescribeConsumerGroupsOptions extends AbstractOptions<DescribeConsu
public boolean includeAuthorizedOperations() {
return includeAuthorizedOperations;
}
}
}

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java
View File

@ -18,20 +18,15 @@
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;
import java.util.Map;
import java.util.concurrent.ExecutionException;
/**
* The result of the {@link KafkaAdminClient#describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)}} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeConsumerGroupsResult {
private final Map<String, KafkaFuture<ConsumerGroupDescription>> futures;

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

@ -17,17 +17,13 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.security.auth.KafkaPrincipal;
import java.util.List;
/**
* Options for {@link Admin#describeDelegationToken(DescribeDelegationTokenOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeDelegationTokenOptions extends AbstractOptions<DescribeDelegationTokenOptions> {
private List<KafkaPrincipal> owners;

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

@ -18,17 +18,13 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.security.token.delegation.DelegationToken;
import java.util.List;
/**
* The result of the {@link KafkaAdminClient#describeDelegationToken(DescribeDelegationTokenOptions)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeDelegationTokenResult {
private final KafkaFuture<List<DelegationToken>> delegationTokens;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesOptions.java
View File

@ -16,13 +16,8 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link AdminClient#describeFeatures(DescribeFeaturesOptions)}.
*
* The API of this class is evolving. See {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeFeaturesOptions extends AbstractOptions<DescribeFeaturesOptions> {
}

6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java
View File

@ -17,17 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#describeLogDirs(Collection)}
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeLogDirsOptions extends AbstractOptions<DescribeLogDirsOptions> {
}

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java
View File

@ -18,20 +18,15 @@
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;
import java.util.Map;
import java.util.concurrent.ExecutionException;
/**
* The result of the {@link Admin#describeLogDirs(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeLogDirsResult {
private final Map<Integer, KafkaFuture<Map<String, LogDirDescription>>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeProducersOptions.java
View File

@ -16,18 +16,13 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Objects;
import java.util.OptionalInt;
/**
* Options for {@link Admin#describeProducers(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeProducersOptions extends AbstractOptions<DescribeProducersOptions> {
private OptionalInt brokerId = OptionalInt.empty();

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

@ -19,14 +19,12 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaException;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutionException;
@InterfaceStability.Evolving
public class DescribeProducersResult {
private final Map<TopicPartition, KafkaFuture<PartitionProducerState>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#describeReplicaLogDirs(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeReplicaLogDirsOptions extends AbstractOptions<DescribeReplicaLogDirsOptions> {
}

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java
View File

@ -18,7 +18,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartitionReplica;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.requests.DescribeLogDirsResponse;
import java.util.Collection;
@ -26,13 +25,9 @@ import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutionException;
/**
* The result of {@link Admin#describeReplicaLogDirs(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeReplicaLogDirsResult {
private final Map<TopicPartitionReplica, KafkaFuture<ReplicaLogDirInfo>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#describeTopics(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeTopicsOptions extends AbstractOptions<DescribeTopicsOptions> {
private boolean includeAuthorizedOperations;

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

@ -20,7 +20,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicCollection;
import org.apache.kafka.common.Uuid;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.HashMap;
@ -29,10 +28,7 @@ import java.util.concurrent.ExecutionException;
/**
* The result of the {@link KafkaAdminClient#describeTopics(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeTopicsResult {
private final Map<Uuid, KafkaFuture<TopicDescription>> topicIdFutures;
private final Map<String, KafkaFuture<TopicDescription>> nameFutures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTransactionsOptions.java
View File

@ -16,16 +16,11 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#describeTransactions(Collection)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeTransactionsOptions extends AbstractOptions<DescribeTransactionsOptions> {
@Override

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

@ -18,14 +18,12 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.clients.admin.internals.CoordinatorKey;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutionException;
@InterfaceStability.Evolving
public class DescribeTransactionsResult {
private final Map<CoordinatorKey, KafkaFuture<TransactionDescription>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions.java
View File

@ -17,15 +17,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.List;
/**
* Options for {@link AdminClient#describeUserScramCredentials(List, DescribeUserScramCredentialsOptions)}
*
* The API of this class is evolving. See {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class DescribeUserScramCredentialsOptions extends AbstractOptions<DescribeUserScramCredentialsOptions> {
}

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

@ -18,7 +18,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.errors.ResourceNotFoundException;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import org.apache.kafka.common.message.DescribeUserScramCredentialsResponseData;
@ -33,10 +32,7 @@ import java.util.stream.Collectors;
/**
* The result of the {@link Admin#describeUserScramCredentials()} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class DescribeUserScramCredentialsResult {
private final KafkaFuture<DescribeUserScramCredentialsResponseData> dataFuture;

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

@ -18,7 +18,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.ElectionType;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Set;
@ -27,6 +26,5 @@ import java.util.Set;
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public final class ElectLeadersOptions extends AbstractOptions<ElectLeadersOptions> {
}

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

@ -21,7 +21,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.ElectionType;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import java.util.Map;
@ -33,7 +32,6 @@ import java.util.Set;
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public final class ElectLeadersResult {
private final KafkaFuture<Map<TopicPartition, Optional<Throwable>>> electionFuture;

5
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenOptions.java
View File

@ -17,14 +17,9 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#expireDelegationToken(byte[], ExpireDelegationTokenOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ExpireDelegationTokenOptions extends AbstractOptions<ExpireDelegationTokenOptions> {
private long expiryTimePeriodMs = -1L;

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

@ -18,14 +18,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* The result of the {@link KafkaAdminClient#expireDelegationToken(byte[], ExpireDelegationTokenOptions)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ExpireDelegationTokenResult {
private final KafkaFuture<Long> expiryTimestamp;

5
clients/src/main/java/org/apache/kafka/clients/admin/FenceProducersOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
/**
* Options for {@link Admin#fenceProducers(Collection, FenceProducersOptions)}
*
* The API of this class is evolving. See {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class FenceProducersOptions extends AbstractOptions<FenceProducersOptions> {
@Override

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

@ -19,7 +19,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.clients.admin.internals.CoordinatorKey;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.utils.ProducerIdAndEpoch;
import java.util.Collection;
@ -28,10 +27,7 @@ import java.util.stream.Collectors;
/**
* The result of the {@link Admin#fenceProducers(Collection)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class FenceProducersResult {
private final Map<CoordinatorKey, KafkaFuture<ProducerIdAndEpoch>> futures;

3
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
View File

@ -85,7 +85,6 @@ import org.apache.kafka.common.Uuid;
import org.apache.kafka.common.acl.AclBinding;
import org.apache.kafka.common.acl.AclBindingFilter;
import org.apache.kafka.common.acl.AclOperation;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.config.ConfigException;
import org.apache.kafka.common.config.ConfigResource;
import org.apache.kafka.common.errors.ApiException;
@ -313,9 +312,7 @@ import static org.apache.kafka.common.utils.Utils.closeQuietly;
* <p>
* This class is thread-safe.
* </p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class KafkaAdminClient extends AdminClient {
/**

5
clients/src/main/java/org/apache/kafka/clients/admin/ListClientMetricsResourcesOptions.java
View File

@ -17,13 +17,8 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#listClientMetricsResources()}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListClientMetricsResourcesOptions extends AbstractOptions<ListClientMetricsResourcesOptions> {
}

3
clients/src/main/java/org/apache/kafka/clients/admin/ListClientMetricsResourcesResult.java
View File

@ -18,7 +18,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import java.util.Collection;
@ -26,9 +25,7 @@ import java.util.Collection;
/**
* The result of the {@link Admin#listClientMetricsResources()} call.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListClientMetricsResourcesResult {
private final KafkaFuture<Collection<ClientMetricsResourceListing>> future;

5
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
View File

@ -17,15 +17,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#listConsumerGroupOffsets(java.util.Map)} and {@link Admin#listConsumerGroupOffsets(String)}.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListConsumerGroupOffsetsOptions extends AbstractOptions<ListConsumerGroupOffsetsOptions> {
private boolean requireStable = false;

3
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java
View File

@ -21,7 +21,6 @@ import org.apache.kafka.clients.admin.internals.CoordinatorKey;
import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.HashMap;
import java.util.Map;
@ -33,9 +32,7 @@ import java.util.stream.Collectors;
* The result of the {@link Admin#listConsumerGroupOffsets(Map)} and
* {@link Admin#listConsumerGroupOffsets(String)} call.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListConsumerGroupOffsetsResult {
final Map<String, KafkaFuture<Map<TopicPartition, OffsetAndMetadata>>> futures;

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

@ -18,17 +18,13 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Objects;
/**
* Specification of consumer group offsets to list using {@link Admin#listConsumerGroupOffsets(java.util.Map)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListConsumerGroupOffsetsSpec {
private Collection<TopicPartition> topicPartitions;

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

@ -20,7 +20,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.ConsumerGroupState;
import org.apache.kafka.common.GroupState;
import org.apache.kafka.common.GroupType;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collections;
import java.util.HashSet;
@ -29,10 +28,7 @@ import java.util.stream.Collectors;
/**
* Options for {@link Admin#listConsumerGroups()}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListConsumerGroupsOptions extends AbstractOptions<ListConsumerGroupsOptions> {
private Set<GroupState> groupStates = Collections.emptySet();

3
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java
View File

@ -18,7 +18,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import java.util.ArrayList;
@ -27,9 +26,7 @@ import java.util.Collection;
/**
* The result of the {@link Admin#listConsumerGroups()} call.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListConsumerGroupsResult {
private final KafkaFutureImpl<Collection<ConsumerGroupListing>> all;
private final KafkaFutureImpl<Collection<ConsumerGroupListing>> valid;

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

@ -17,16 +17,12 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.IsolationLevel;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link AdminClient#listOffsets(Map)}.
*
* The API of this class is evolving, see {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class ListOffsetsOptions extends AbstractOptions<ListOffsetsOptions> {
private final IsolationLevel isolationLevel;

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

@ -18,7 +18,6 @@ package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.HashMap;
import java.util.Map;
@ -27,10 +26,7 @@ import java.util.concurrent.ExecutionException;
/**
* The result of the {@link AdminClient#listOffsets(Map)} call.
*
* The API of this class is evolving, see {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class ListOffsetsResult {
private final Map<TopicPartition, KafkaFuture<ListOffsetsResultInfo>> futures;

5
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsOptions.java
View File

@ -17,13 +17,8 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link AdminClient#listPartitionReassignments(ListPartitionReassignmentsOptions)}
*
* The API of this class is evolving. See {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class ListPartitionReassignmentsOptions extends AbstractOptions<ListPartitionReassignmentsOptions> {
}

5
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
/**
* Options for {@link Admin#listTopics()}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListTopicsOptions extends AbstractOptions<ListTopicsOptions> {
private boolean listInternal = false;

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

@ -18,7 +18,6 @@
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.Map;
@ -26,10 +25,7 @@ import java.util.Set;
/**
* The result of the {@link Admin#listTopics()} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListTopicsResult {
final KafkaFuture<Map<String, TopicListing>> future;

5
clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsOptions.java
View File

@ -17,8 +17,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
@ -27,10 +25,7 @@ import java.util.Set;
/**
* Options for {@link Admin#listTransactions()}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListTransactionsOptions extends AbstractOptions<ListTransactionsOptions> {
private Set<TransactionState> filteredStates = Collections.emptySet();
private Set<Long> filteredProducerIds = Collections.emptySet();

3
clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsResult.java
View File

@ -17,7 +17,6 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.internals.KafkaFutureImpl;
import java.util.ArrayList;
@ -31,9 +30,7 @@ import java.util.Set;
/**
* The result of the {@link Admin#listTransactions()} call.
* <p>
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class ListTransactionsResult {
private final KafkaFuture<Map<Integer, KafkaFutureImpl<Collection<TransactionListing>>>> future;

5
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java
View File

@ -17,17 +17,12 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.List;
import java.util.Map;
/**
* Describes new partitions for a particular topic in a call to {@link Admin#createPartitions(Map)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class NewPartitions {
private final int totalCount;

5
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Describe records to delete in a call to {@link Admin#deleteRecords(Map)}
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class RecordsToDelete {
private final long offset;

5
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java
View File

@ -16,8 +16,6 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
@ -26,10 +24,7 @@ import java.util.Set;
/**
* Options for {@link AdminClient#removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)}.
* It carries the members to be removed from the consumer group.
*
* The API of this class is evolving, see {@link AdminClient} for details.
*/
@InterfaceStability.Evolving
public class RemoveMembersFromConsumerGroupOptions extends AbstractOptions<RemoveMembersFromConsumerGroupOptions> {
private final Set<MemberToRemove> members;

5
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenOptions.java
View File

@ -17,14 +17,9 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#renewDelegationToken(byte[], RenewDelegationTokenOptions)}.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class RenewDelegationTokenOptions extends AbstractOptions<RenewDelegationTokenOptions> {
private long renewTimePeriodMs = -1;

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

@ -18,14 +18,10 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* The result of the {@link KafkaAdminClient#expireDelegationToken(byte[], ExpireDelegationTokenOptions)} call.
*
* The API of this class is evolving, see {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class RenewDelegationTokenResult {
private final KafkaFuture<Long> expiryTimestamp;

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

@ -17,13 +17,11 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
import java.util.OptionalLong;
import java.util.Set;
@InterfaceStability.Evolving
public class TransactionDescription {
private final int coordinatorId;
private final TransactionState state;

3
clients/src/main/java/org/apache/kafka/clients/admin/TransactionListing.java
View File

@ -16,11 +16,8 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
@InterfaceStability.Evolving
public class TransactionListing {
private final String transactionalId;
private final long producerId;

3
clients/src/main/java/org/apache/kafka/clients/admin/TransactionState.java
View File

@ -16,14 +16,11 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Arrays;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
@InterfaceStability.Evolving
public enum TransactionState {
ONGOING("Ongoing"),
PREPARE_ABORT("PrepareAbort"),

5
clients/src/main/java/org/apache/kafka/clients/admin/UnregisterBrokerOptions.java
View File

@ -17,13 +17,8 @@
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
/**
* Options for {@link Admin#unregisterBroker(int, UnregisterBrokerOptions)}.
*
* The API of this class is evolving. See {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class UnregisterBrokerOptions extends AbstractOptions<UpdateFeaturesOptions> {
}

5
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java
View File

@ -16,16 +16,11 @@
*/
package org.apache.kafka.clients.admin;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Map;
/**
* Options for {@link AdminClient#updateFeatures(Map, UpdateFeaturesOptions)}.
*
* The API of this class is evolving. See {@link Admin} for details.
*/
@InterfaceStability.Evolving
public class UpdateFeaturesOptions extends AbstractOptions<UpdateFeaturesOptions> {
private boolean validateOnly = false;

5
clients/src/main/java/org/apache/kafka/common/ElectionType.java
View File

@ -17,17 +17,12 @@
package org.apache.kafka.common;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Arrays;
import java.util.Set;
/**
* Options for {@link org.apache.kafka.clients.admin.Admin#electLeaders(ElectionType, Set, org.apache.kafka.clients.admin.ElectLeadersOptions)}.
*
* The API of this class is evolving, see {@link org.apache.kafka.clients.admin.Admin} for details.
*/
@InterfaceStability.Evolving
public enum ElectionType {
PREFERRED((byte) 0), UNCLEAN((byte) 1);

5
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.common.acl;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
/**
* Represents an access control entry. ACEs are a tuple of principal, host, operation, and permissionType.
*
* The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
*/
@InterfaceStability.Evolving
public class AccessControlEntry {
final AccessControlEntryData data;

5
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java
View File

@ -17,16 +17,11 @@
package org.apache.kafka.common.acl;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Objects;
/**
* Represents a filter which matches access control entries.
*
* The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
*/
@InterfaceStability.Evolving
public class AccessControlEntryFilter {
private final AccessControlEntryData data;

4
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java
View File

@ -17,17 +17,13 @@
package org.apache.kafka.common.acl;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.resource.ResourcePattern;
import java.util.Objects;
/**
* Represents a binding between a resource pattern and an access control entry.
*
* The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
*/
@InterfaceStability.Evolving
public class AclBinding {
private final ResourcePattern pattern;
private final AccessControlEntry entry;

4
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java
View File

@ -17,17 +17,13 @@
package org.apache.kafka.common.acl;
import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.resource.ResourcePatternFilter;
import java.util.Objects;
/**
* A filter which can match AclBinding objects.
*
* The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
*/
@InterfaceStability.Evolving
public class AclBindingFilter {
private final ResourcePatternFilter patternFilter;
private final AccessControlEntryFilter entryFilter;

4
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java
View File

@ -17,8 +17,6 @@
package org.apache.kafka.common.acl;
import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.HashMap;
import java.util.Locale;
@ -38,9 +36,7 @@ import java.util.Locale;
*
* <li><code>ALLOW ALTER_CONFIGS</code> implies <code>ALLOW DESCRIBE_CONFIGS</code>
* </ul>
* The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
*/
@InterfaceStability.Evolving
public enum AclOperation {
/**
* Represents any AclOperation which this client cannot understand, perhaps because this

Some files were not shown because too many files have changed in this diff Show More