@InterfaceStability.Evolving public class CreateTopicsOptions extends AbstractOptions<CreateTopicsOptions>
Admin.createTopics(Collection)
.
The API of this class is evolving, see Admin
for details.timeoutMs
Constructor and Description |
---|
CreateTopicsOptions() |
Modifier and Type | Method and Description |
---|---|
CreateTopicsOptions |
retryOnQuotaViolation(boolean retryOnQuotaViolation)
Set to true if quota violation should be automatically retried.
|
boolean |
shouldRetryOnQuotaViolation()
Returns true if quota violation should be automatically retried.
|
boolean |
shouldValidateOnly()
Return true if the request should be validated without creating the topic.
|
CreateTopicsOptions |
timeoutMs(java.lang.Integer timeoutMs)
Set the timeout in milliseconds for this operation or
null if the default api timeout for the
AdminClient should be used. |
CreateTopicsOptions |
validateOnly(boolean validateOnly)
Set to true if the request should be validated without creating the topic.
|
timeoutMs
public CreateTopicsOptions timeoutMs(java.lang.Integer timeoutMs)
null
if the default api timeout for the
AdminClient should be used.timeoutMs
in class AbstractOptions<CreateTopicsOptions>
public CreateTopicsOptions validateOnly(boolean validateOnly)
public boolean shouldValidateOnly()
public CreateTopicsOptions retryOnQuotaViolation(boolean retryOnQuotaViolation)
public boolean shouldRetryOnQuotaViolation()