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.