Class CreateTopicsOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<CreateTopicsOptions>
org.apache.kafka.clients.admin.CreateTopicsOptions

@Evolving
public class CreateTopicsOptions
extends AbstractOptions<CreateTopicsOptions>
Options for Admin.createTopics(Collection). The API of this class is evolving, see Admin for details.
  • Constructor Details

    • CreateTopicsOptions

      public CreateTopicsOptions()
  • Method Details

    • timeoutMs

      public CreateTopicsOptions timeoutMs​(Integer timeoutMs)
      Set the timeout in milliseconds for this operation or null if the default api timeout for the AdminClient should be used.
      Overrides:
      timeoutMs in class AbstractOptions<CreateTopicsOptions>
    • validateOnly

      public CreateTopicsOptions validateOnly​(boolean validateOnly)
      Set to true if the request should be validated without creating the topic.
    • shouldValidateOnly

      public boolean shouldValidateOnly()
      Return true if the request should be validated without creating the topic.
    • retryOnQuotaViolation

      public CreateTopicsOptions 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.