Package org.apache.kafka.clients.admin
Class CreatePartitionsOptions
java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<CreatePartitionsOptions>
org.apache.kafka.clients.admin.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
-
Method Summary
Modifier and TypeMethodDescriptionretryOnQuotaViolation
(boolean retryOnQuotaViolation) Set to true if quota violation should be automatically retried.boolean
Returns true if quota violation should be automatically retried.boolean
Return true if the request should be validated without creating new partitions.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.
-