Open alexshiloov opened 2 months ago
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
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