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

isRetriable

Description

public function isRetriable(): bool {}

Indicates that the operation that caused this exception can be retried.

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->isRetriable()) {
        // action can be retried
    }
}