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, seeAdmin
for details.
-
-
Constructor Summary
Constructors Constructor Description DeleteTopicsOptions()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DeleteTopicsOptions
retryOnQuotaViolation(boolean retryOnQuotaViolation)
Set to true if quota violation should be automatically retried.boolean
shouldRetryOnQuotaViolation()
Returns true if quota violation should be automatically retried.DeleteTopicsOptions
timeoutMs(Integer timeoutMs)
Set the timeout in milliseconds for this operation ornull
if 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 ornull
if the default api timeout for the AdminClient should be used.- Overrides:
timeoutMs
in 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.
-
-