Class DeleteTopicsOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<DeleteTopicsOptions>
org.apache.kafka.clients.admin.DeleteTopicsOptions
public class DeleteTopicsOptionsextends AbstractOptions<DeleteTopicsOptions>
Options for Admin.deleteTopics(Collection).

  • Constructor Details

    • DeleteTopicsOptions

      public DeleteTopicsOptions()

  • Method Details

    • timeoutMs

      public DeleteTopicsOptions 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<DeleteTopicsOptions>

    • retryOnQuotaViolation

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