Class KafkaErrorException

Class \RdKafka\KafkaErrorException

• extends \RdKafka\Exception

Methods

__construct()

public __construct ( 
    string $message, 
    int $code, 
    string $error_string, 
    bool $isFatal = false, 
    bool $isRetriable = false, 
    bool $transactionRequiresAbort = false
 ): 

Parameters

message string

code int

error_string string

isFatal bool

isRetriable bool

transactionRequiresAbort bool

fromCData()

public static fromCData ( 
    \FFI\CData $error
 ): mixed

Parameters

error \FFI\CData

Returns

mixed

getErrorString()

public getErrorString (  ): string

Returns

string

isFatal()

public isFatal (  ): bool

Returns

bool

isRetriable()

public isRetriable (  ): bool

Returns

bool

transactionRequiresAbort()

public transactionRequiresAbort (  ): bool

Returns

bool

Test Coverage 💚

• 💚 Lines: 90.91% (20 / 22)
• 💛 Methods: 83.33% (5 / 6)