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.
  • Constructor Details

    • CreatePartitionsOptions

      public CreatePartitionsOptions()
  • Method Details

    • 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.