Package org.apache.kafka.clients.admin
Class CreatePartitionsOptions
java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<CreatePartitionsOptions>
org.apache.kafka.clients.admin.CreatePartitionsOptions
@Evolving public class CreatePartitionsOptions extends AbstractOptions<CreatePartitionsOptions>
Options for
Admin.createPartitions(Map).
The API of this class is evolving, see Admin for details.-
Field Summary
Fields inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs -
Constructor Summary
Constructors Constructor Description CreatePartitionsOptions() -
Method Summary
Modifier and Type Method Description CreatePartitionsOptionsretryOnQuotaViolation(boolean retryOnQuotaViolation)Set to true if quota violation should be automatically retried.booleanshouldRetryOnQuotaViolation()Returns true if quota violation should be automatically retried.booleanvalidateOnly()Return true if the request should be validated without creating new partitions.CreatePartitionsOptionsvalidateOnly(boolean validateOnly)Set to true if the request should be validated without creating new partitions.Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs, timeoutMs
-
Constructor Details
-
CreatePartitionsOptions
public CreatePartitionsOptions()
-
-
Method Details
-
validateOnly
public boolean validateOnly()Return true if the request should be validated without creating new partitions. -
validateOnly
Set to true if the request should be validated without creating new partitions. -
retryOnQuotaViolation
Set to true if quota violation should be automatically retried. -
shouldRetryOnQuotaViolation
public boolean shouldRetryOnQuotaViolation()Returns true if quota violation should be automatically retried.
-