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 forAdmin.createPartitions(Map)
. The API of this class is evolving, seeAdmin
for details.
-
-
Field Summary
-
Fields inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs
-
-
Constructor Summary
Constructors Constructor Description CreatePartitionsOptions()
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Method Detail
-
validateOnly
public boolean validateOnly()
Return true if the request should be validated without creating new partitions.
-
validateOnly
public CreatePartitionsOptions validateOnly(boolean validateOnly)
Set to true if the request should be validated without creating new partitions.
-
retryOnQuotaViolation
public CreatePartitionsOptions retryOnQuotaViolation(boolean retryOnQuotaViolation)
Set to true if quota violation should be automatically retried.
-
shouldRetryOnQuotaViolation
public boolean shouldRetryOnQuotaViolation()
Returns true if quota violation should be automatically retried.
-
-