Class DeleteTopicsOptions

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

@Evolving
public class DeleteTopicsOptions
extends AbstractOptions<DeleteTopicsOptions>
Options for Admin.deleteTopics(Collection). The API of this class is evolving, see Admin for details.
  • 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.