Package org.apache.kafka.clients.producer.internals

Class TransactionalRequestResult

java.lang.Object
org.apache.kafka.clients.producer.internals.TransactionalRequestResult
public final class TransactionalRequestResult extends Object

  • Constructor Details

    • TransactionalRequestResult

      public TransactionalRequestResult(String operation)

  • Method Details

    • fail

      public void fail(RuntimeException error)

    • done

      public void done()

    • await

      public void await()

    • await

      public void await(long timeout, TimeUnit unit)

    • error

      public RuntimeException error()

    • isSuccessful

      public boolean isSuccessful()

    • isCompleted

      public boolean isCompleted()

    • isAcked

      public boolean isAcked()