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