Commit ec8ffe2

authored

use kafka_err2str (#14)

1 parent 9e1ce5a commit ec8ffe2Copy full SHA for ec8ffe2

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -22,7 +22,7 @@`
`22`	`22`	`// you can see if your message was truly sent, this can be especially of importance if you poll async`
`23`	`23`	`$conf->setDrMsgCb(function (Producer $kafka, Message $message) {`
`24`	`24`	`if (RD_KAFKA_RESP_ERR_NO_ERROR !== $message->err) {`
`25`		`- $errorStr = rd_kafka_err2str($message->err);`
	`25`	`+ $errorStr = kafka_err2str($message->err);`
`26`	`26`
`27`	`27`	`echo sprintf('Message FAILED (%s, %s) to send with payload => %s', $message->err, $errorStr, $message->payload) . PHP_EOL;`
`28`	`28`	`} else {`

Comments

(0)