(No version information available, might only be in Git)

RdKafka\Producer::abortTransactionAbort current transaction


public RdKafka\Producer::abortTransaction ( integer $timeout_ms ) : void

This function should also be used to recover from non-fatal abortable transaction errors. Any outstanding messages will be purged and fail with RD_KAFKA_RESP_ERR__PURGE_INFLIGHT or RD_KAFKA_RESP_ERR__PURGE_QUEUE.


timeout_ms (integer)

Specifies the amount of time (in milliseconds) that the call will try to abort the current transaction.

Return Values

In case of success returns NULL, in case of error a RdKafka\KafkaErrorException will be thrown.