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));
}