Documentation of php-simple-kafka-client
Edit this page

transactionRequiresAbort

Description

public function transactionRequiresAbort(): bool {}

Check if error needs the transaction to be aborted

Example

$conf = SimpleKafkaClient\Configuration();
$conf->set('metadata.broker.list', 'kafka:9092');
$producer = new SimpleKafkaClient\Producer($conf);
try {
    $producer->initTransactions(10000);
} catch (SimpleKafkaClient\KafkaErrorException $e) {
    if ($e->$transactionRequiresAbort()) {
        $producer->abortTransaction(10000);
    }
}