Package org.apache.kafka.clients.admin
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 forAdmin.deleteTopics(Collection). The API of this class is evolving, seeAdminfor details.
-
-
Field Summary
-
Fields inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs
-
-
Constructor Summary
Constructors Constructor Description DeleteTopicsOptions()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DeleteTopicsOptionsretryOnQuotaViolation(boolean retryOnQuotaViolation)Set to true if quota violation should be automatically retried.booleanshouldRetryOnQuotaViolation()Returns true if quota violation should be automatically retried.DeleteTopicsOptionstimeoutMs(Integer timeoutMs)Set the timeout in milliseconds for this operation ornullif the default api timeout for the AdminClient should be used.-
Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs
-
-
-
-
Method Detail
-
timeoutMs
public DeleteTopicsOptions timeoutMs(Integer timeoutMs)
Set the timeout in milliseconds for this operation ornullif the default api timeout for the AdminClient should be used.- Overrides:
timeoutMsin classAbstractOptions<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.
-
-