TransactionMetadata class

TransactionMetadata.java

public class TransactionResponse {
  
  /**
   * All the error codes that may be returned by transactional methods.
   */
  public enum TransactionError {
    PRODUCER_FENCED,
    NO_PID_MAPPING,
    NOT_COORDINATOR_FOR_APP_ID,
    INVALID_TXN_REQUEST,
    COORDINATOR_NOT_AVAILABLE,
    INVALID_SEQUENCE_NUMBER
  }
  
  /** 
   * Returns true if the request was successful, false otherwise.
   */
  public boolean isSuccess();
  
  /**
   * If isSuccess returns false, this method will return the error that occurred in processing the transaction.
   */
  public TransactionError getError(); 
  
  /**
   * The list of partitions currently part of the transaction.
   */
  public List<TopicPartition> partitions();
  
  /**
   * The current epoch of this AppId.
   */
  public long epoch();
  
  /**
   * The AppId for this transaction.
   */
  public String appId();
}