Break out DestroyKafkaConsumer function.
[R/project-using-kafka-in-R.git] / R / DestroyKafkaConsumer.R
1 DestroyKafkaConsumer <- function(consumer.base.uri) {
2   response <- DELETE(url = consumer.base.uri,
3          content_type("application/vnd.kafka.v2+json"))
4   if(response$status_code == 204) {
5     return(TRUE)
6     } else stop(response)
7 }