RdKafka\Producer::abortTransaction

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

RdKafka\Producer::abortTransaction — Abort current transaction

Description

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.

Parameters

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.