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 CreatePartitionsOptions
retryOnQuotaViolation(boolean retryOnQuotaViolation)
Set to true if quota violation should be automatically retried.boolean
shouldRetryOnQuotaViolation()
Returns true if quota violation should be automatically retried.boolean
validateOnly()
Return true if the request should be validated without creating new partitions.CreatePartitionsOptions
validateOnly(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.
-