enqueue-dev icon indicating copy to clipboard operation
enqueue-dev copied to clipboard

RdKafkaConsumer crash

Open alexshiloov opened this issue 1 year ago • 0 comments

175 line https://github.com/php-enqueue/rdkafka/blob/master/RdKafkaConsumer.php#L175

$message = $this->serializer->toMessage($kafkaMessage->payload);

It will lead to crash, if someone push to kafka empty msg for example. I think it is not correct for crashing, maybe skipping this msg or returning null

alexshiloov avatar Aug 26 '24 14:08 alexshiloov