Package org.apache.kafka.clients.admin
Class CreateTopicsOptions
java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<CreateTopicsOptions>
org.apache.kafka.clients.admin.CreateTopicsOptions
Options for
Admin.createTopics(Collection)
.
The API of this class is evolving, see Admin
for details.-
Field Summary
Fields inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionretryOnQuotaViolation
(boolean retryOnQuotaViolation) Set to true if quota violation should be automatically retried.boolean
Returns true if quota violation should be automatically retried.boolean
Return true if the request should be validated without creating the topic.Set the timeout in milliseconds for this operation ornull
if the default api timeout for the AdminClient should be used.validateOnly
(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
-
Constructor Details
-
CreateTopicsOptions
public CreateTopicsOptions()
-
-
Method Details
-
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<CreateTopicsOptions>
-
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
Set to true if quota violation should be automatically retried. -
shouldRetryOnQuotaViolation
public boolean shouldRetryOnQuotaViolation()Returns true if quota violation should be automatically retried.
-