php-enqueue/enqueue-dev

RdKafkaConsumer crash

alexshiloov opened this issue · 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