Package org.apache.kafka.clients.admin

Class DescribeClusterOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<DescribeClusterOptions>
org.apache.kafka.clients.admin.DescribeClusterOptions
public class DescribeClusterOptions extends AbstractOptions<DescribeClusterOptions>
Options for Admin.describeCluster().

  • Constructor Details

    • DescribeClusterOptions

      public DescribeClusterOptions()

  • Method Details

    • timeoutMs

      public DescribeClusterOptions timeoutMs(Integer timeoutMs)
      Set the timeout in milliseconds for this operation or null if the default api timeout for the AdminClient should be used.
      Overrides:
      timeoutMs in class AbstractOptions<DescribeClusterOptions>

    • includeAuthorizedOperations

      public DescribeClusterOptions includeAuthorizedOperations(boolean includeAuthorizedOperations)

    • includeFencedBrokers

      public DescribeClusterOptions includeFencedBrokers(boolean includeFencedBrokers)

    • includeAuthorizedOperations

      public boolean includeAuthorizedOperations()
      Specify if authorized operations should be included in the response. Note that some older brokers cannot not supply this information even if it is requested.

    • includeFencedBrokers

      public boolean includeFencedBrokers()
      Specify if fenced brokers should be included in the response. Note that some older brokers cannot not supply this information even if it is requested.