Not calling flush can lead to message loss

[Walker-P]

There is a bug,Not calling flush can lead to message loss.

public function publish($channel, $message) { $topic = $this->producer->newTopic($channel); $topic->produce(RD_KAFKA_PARTITION_UA, 0, Utils::serializeMessage($message)); }