org.apache.kafka.clients.admin

Class CreatePartitionsOptions

java.lang.Object

org.apache.kafka.clients.admin.AbstractOptions<CreatePartitionsOptions>

org.apache.kafka.clients.admin.CreatePartitionsOptions

@InterfaceStability.Evolving
public class CreatePartitionsOptions
extends AbstractOptions<CreatePartitionsOptions>

Options for Admin.createPartitions(Map). The API of this class is evolving, see Admin for details.

Constructor Summary

Constructors

Constructor and Description
CreatePartitionsOptions()

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreatePartitionsOptions

public CreatePartitionsOptions()

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.