Kafka

allid = array(allthedeletedids);
foreach ($allid as $id){
query: delete from table where id = id;
}