Skip to content

Commit ec8ffe2

Browse files
use kafka_err2str (#14)
1 parent 9e1ce5a commit ec8ffe2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: src/ext-php-simple-kafka-client/pure-php/producer.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
// you can see if your message was truly sent, this can be especially of importance if you poll async
2323
$conf->setDrMsgCb(function (Producer $kafka, Message $message) {
2424
if (RD_KAFKA_RESP_ERR_NO_ERROR !== $message->err) {
25-
$errorStr = rd_kafka_err2str($message->err);
25+
$errorStr = kafka_err2str($message->err);
2626

2727
echo sprintf('Message FAILED (%s, %s) to send with payload => %s', $message->err, $errorStr, $message->payload) . PHP_EOL;
2828
} else {

0 commit comments

Comments
 (0)