Class DescribeMirrorsOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<DescribeMirrorsOptions>
org.apache.kafka.clients.admin.DescribeMirrorsOptions
@Confluent @Evolving public class DescribeMirrorsOptions extends AbstractOptions<DescribeMirrorsOptions>
Options for ConfluentAdmin.describeMirrors(Collection, DescribeMirrorsOptions). The API of this class is evolving, see Admin for details.

  • Constructor Details

    • DescribeMirrorsOptions

      public DescribeMirrorsOptions()

  • Method Details

    • linkNames

      public Collection<String> linkNames()
      Returns:
      The link names to filter by.

    • states

      public Collection<String> states()
      Returns:
      The states to filter by.

    • includeStateTransitionErrors

      public boolean includeStateTransitionErrors()

    • describeRemoteMirrors

      public boolean describeRemoteMirrors()
      Returns:
      Whether to describe the mirror topics on the remote clusters. Only works for bidirectional links.

    • linkNames

      public DescribeMirrorsOptions linkNames(Collection<String> linkNames)
      Parameters:
      linkNames - Sets the link names to filter by.
      Returns:
      The DescribeMirrorsOptions which is updated.

    • states

      public DescribeMirrorsOptions states(Collection<String> states)
      Parameters:
      states - Sets the states to filter by.
      Returns:
      The DescribeMirrorsOptions which is updated.

    • includeStateTransitionErrors

      public DescribeMirrorsOptions includeStateTransitionErrors(boolean includeStateTransitionErrors)

    • describeRemoteMirrors

      public DescribeMirrorsOptions describeRemoteMirrors(boolean describeRemoteMirrors)
      Whether to describe the mirror topics on the remote clusters. Only works for bidirectional links.