try
                    {
                        $kafkaTopic->produce(RD_KAFKA_PARTITION_UA, 0, Json::encode($data));
                        $rk->poll(0);
                        if(method_exists($rk,'flush'))