Package org.apache.kafka.clients.admin

Class AbstractOptions<T extends AbstractOptions>

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<T>
Direct Known Subclasses:
AbortTransactionOptions, AlterClientQuotasOptions, AlterConfigsOptions, AlterConsumerGroupOffsetsOptions, AlterPartitionReassignmentsOptions, AlterReplicaLogDirsOptions, AlterUserScramCredentialsOptions, CreateAclsOptions, CreateDelegationTokenOptions, CreatePartitionsOptions, CreateTopicsOptions, DeleteAclsOptions, DeleteConsumerGroupOffsetsOptions, DeleteConsumerGroupsOptions, DeleteRecordsOptions, DeleteTopicsOptions, DescribeAclsOptions, DescribeClientQuotasOptions, DescribeClusterOptions, DescribeConfigsOptions, DescribeConsumerGroupsOptions, DescribeDelegationTokenOptions, DescribeFeaturesOptions, DescribeLogDirsOptions, DescribeProducersOptions, DescribeReplicaLogDirsOptions, DescribeTopicsOptions, DescribeTransactionsOptions, DescribeUserScramCredentialsOptions, ElectLeadersOptions, ExpireDelegationTokenOptions, ListConsumerGroupOffsetsOptions, ListConsumerGroupsOptions, ListOffsetsOptions, ListPartitionReassignmentsOptions, ListTopicsOptions, ListTransactionsOptions, RemoveMembersFromConsumerGroupOptions, RenewDelegationTokenOptions, UnregisterBrokerOptions, UpdateFeaturesOptions
public abstract class AbstractOptions<T extends AbstractOptions> extends Object

  • Field Details

    • timeoutMs

      protected Integer timeoutMs

  • Constructor Details

    • AbstractOptions

      public AbstractOptions()

  • Method Details

    • timeoutMs

      public T timeoutMs(Integer timeoutMs)
      Set the timeout in milliseconds for this operation or null if the default api timeout for the AdminClient should be used.

    • timeoutMs

      public Integer timeoutMs()
      The timeout in milliseconds for this operation or null if the default api timeout for the AdminClient should be used.