Class CreatePartitionsOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<CreatePartitionsOptions>
org.apache.kafka.clients.admin.CreatePartitionsOptions
public class CreatePartitionsOptionsextends AbstractOptions<CreatePartitionsOptions>
Options for Admin.createPartitions(Map).

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