Package org.apache.kafka.clients.admin

Class AbstractOptions<T extends AbstractOptions>

java.lang.Object

org.apache.kafka.clients.admin.AbstractOptions<T>

Direct Known Subclasses:

AlterConfigsOptions, AlterReplicaLogDirsOptions, CreateAclsOptions, CreateDelegationTokenOptions, CreatePartitionsOptions, CreateTopicsOptions, DeleteAclsOptions, DeleteConsumerGroupsOptions, DeleteRecordsOptions, DeleteTopicsOptions, DescribeAclsOptions, DescribeClusterOptions, DescribeConfigsOptions, DescribeConsumerGroupsOptions, DescribeDelegationTokenOptions, DescribeLogDirsOptions, DescribeReplicaLogDirsOptions, DescribeTopicsOptions, ExpireDelegationTokenOptions, ListConsumerGroupOffsetsOptions, ListConsumerGroupsOptions, ListTopicsOptions, RenewDelegationTokenOptions

public abstract class AbstractOptions<T extends AbstractOptions>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.Integer	timeoutMs

Constructor Summary

Constructors

Constructor	Description
AbstractOptions()

Method Summary

Modifier and Type	Method	Description
java.lang.Integer	timeoutMs()	The request timeout in milliseconds for this operation or null if the default request timeout for the AdminClient should be used.
T	timeoutMs(java.lang.Integer timeoutMs)	Set the request timeout in milliseconds for this operation or null if the default request timeout for the AdminClient should be used.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

timeoutMs

protected java.lang.Integer timeoutMs

Constructor Detail

AbstractOptions

public AbstractOptions()

Method Detail

timeoutMs

public T timeoutMs(java.lang.Integer timeoutMs)

Set the request timeout in milliseconds for this operation or null if the default request timeout for the AdminClient should be used.

timeoutMs

public java.lang.Integer timeoutMs()

The request timeout in milliseconds for this operation or null if the default request timeout for the AdminClient should be used.