Class TransactionalProducer.TransactionHolder<KafkaTransactionState>

  • Enclosing class:
    TransactionalProducer

    public static final class TransactionalProducer.TransactionHolder<KafkaTransactionState>
    extends Object
    Adds metadata (currently only the start time of the transaction) to the transaction object.
    • Constructor Detail

      • TransactionHolder

        public TransactionHolder​(com.networknt.kafka.producer.TransactionalProducer.KafkaTransactionState handle,
                                 long transactionStartTime)