Commit 6f56d4a

committed

improve cb

1 parent fdc5f8d commit 6f56d4aCopy full SHA for 6f56d4a

File tree

-2

lines changed

-2

lines changed

Lines changed: 1 addition & 1 deletion

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

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ function echoTransactionError(KafkaErrorException $e) {`
`56`	`56`	`// This callback processes the delivery reports from the broker`
`57`	`57`	`// you can see if your message was truly sent`
`58`	`58`	`$conf->setDrMsgCb(function (Producer $kafka, Message $message) {`
`59`		`- if ($message->err) {`
	`59`	`+ if (RD_KAFKA_RESP_ERR_NO_ERROR !== $message->err) {`
`60`	`60`	`$errorStr = rd_kafka_err2str($message->err);`
`61`	`61`
`62`	`62`	`echo sprintf('Message FAILED (%s, %s) to send with payload => %s', $message->err, $errorStr, $message->payload) . PHP_EOL;`

Comments

(0)