org.apache.kafka.clients.admin

Class ListTransactionsOptions

java.lang.Object

org.apache.kafka.clients.admin.AbstractOptions<ListTransactionsOptions>

org.apache.kafka.clients.admin.ListTransactionsOptions

@InterfaceStability.Evolving
public class ListTransactionsOptions
extends AbstractOptions<ListTransactionsOptions>

Options for Admin.listTransactions(). The API of this class is evolving, see Admin for details.

Field Summary

Fields inherited from class org.apache.kafka.clients.admin.AbstractOptions

timeoutMs

Constructor Summary

Constructors

Constructor and Description
ListTransactionsOptions()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Set<Long>	filteredProducerIds() Returns the set of producerIds that are being filtered or empty if none have been specified.
Set<TransactionState>	filteredStates() Returns the set of states to be filtered or empty if no states have been specified.
ListTransactionsOptions	filterProducerIds(Collection<Long> producerIdFilters) Filter only the transactions from producers in a specific set of producerIds.
ListTransactionsOptions	filterStates(Collection<TransactionState> states) Filter only the transactions that are in a specific set of states.
int	hashCode()
String	toString()

Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions

timeoutMs, timeoutMs

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ListTransactionsOptions

public ListTransactionsOptions()

Method Detail

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