Package org.apache.kafka.clients.admin
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 forAdmin.createTopics(Collection). The API of this class is evolving, seeAdminfor details.
-
-
Constructor Summary
Constructors Constructor Description CreateTopicsOptions()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CreateTopicsOptionsretryOnQuotaViolation(boolean retryOnQuotaViolation)Set to true if quota violation should be automatically retried.booleanshouldRetryOnQuotaViolation()Returns true if quota violation should be automatically retried.booleanshouldValidateOnly()Return true if the request should be validated without creating the topic.CreateTopicsOptionstimeoutMs(Integer timeoutMs)Set the timeout in milliseconds for this operation ornullif the default api timeout for the AdminClient should be used.CreateTopicsOptionsvalidateOnly(boolean validateOnly)Set to true if the request should be validated without creating the topic.-
Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs
-
-
-
-
Method Detail
-
timeoutMs
public CreateTopicsOptions 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<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.
-
-