X-Git-Url: http://git.vanrenterghem.biz/R/project-using-kafka-in-R.git/blobdiff_plain/7fa65fd2e51d4d96b6e5f895c29819c5d9ad31fb..9948b03c3477ca42cdff48813f6ed281ad00747a:/R/DestroyKafkaConsumer.R

diff --git a/R/DestroyKafkaConsumer.R b/R/DestroyKafkaConsumer.R
new file mode 100644
index 0000000..940535a
--- /dev/null
+++ b/R/DestroyKafkaConsumer.R
@@ -0,0 +1,7 @@
+DestroyKafkaConsumer <- function(consumer.base.uri) {
+  response <- DELETE(url = consumer.base.uri,
+         content_type("application/vnd.kafka.v2+json"))
+  if(response$status_code == 204) {
+    return(TRUE)
+    } else stop(response)
+}
\ No newline at end of file