Class ListTransactionsOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<ListTransactionsOptions>
org.apache.kafka.clients.admin.ListTransactionsOptions

@Evolving public class ListTransactionsOptions extends AbstractOptions<ListTransactionsOptions>
Options for Admin.listTransactions(). The API of this class is evolving, see Admin for details.
  • Constructor Details

    • ListTransactionsOptions

      public ListTransactionsOptions()
  • Method Details

    • filterStates

      public ListTransactionsOptions filterStates(Collection<TransactionState> states)
      Filter only the transactions that are in a specific set of states. If no filter is specified or if the passed set of states is empty, then transactions in all states will be returned.
      Parameters:
      states - the set of states to filter by
      Returns:
      this object
    • filterProducerIds

      public ListTransactionsOptions filterProducerIds(Collection<Long> producerIdFilters)
      Filter only the transactions from producers in a specific set of producerIds. If no filter is specified or if the passed collection of producerIds is empty, then the transactions of all producerIds will be returned.
      Parameters:
      producerIdFilters - the set of producerIds to filter by
      Returns:
      this object
    • filteredStates

      public Set<TransactionState> filteredStates()
      Returns the set of states to be filtered or empty if no states have been specified.
      Returns:
      the current set of filtered states (empty means that no states are filtered and all all transactions will be returned)
    • filteredProducerIds

      public Set<Long> filteredProducerIds()
      Returns the set of producerIds that are being filtered or empty if none have been specified.
      Returns:
      the current set of filtered states (empty means that no producerIds are filtered and all transactions will be returned)
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object