Package org.apache.kafka.clients.admin

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

    • filterOnDuration

      public ListTransactionsOptions filterOnDuration(long durationMs)
      Filter only the transactions that are running longer than the specified duration. If no filter is specified or if the passed duration ms is less than 0, then the all transactions will be returned.
      Parameters:
      durationMs - the duration in milliseconds 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 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)

    • filteredDuration

      public long filteredDuration()
      Returns the duration ms value being filtered.
      Returns:
      the current duration filter value in ms (negative value means transactions are not filtered by duration)

    • 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