X-Git-Url: http://git.vanrenterghem.biz/R/project-using-kafka-in-R.git/blobdiff_plain/ad70a446e1f9c1d371008dc32f7374a7e3a54907..7fa65fd2e51d4d96b6e5f895c29819c5d9ad31fb:/R/CreateKafkaConsumer.R

diff --git a/R/CreateKafkaConsumer.R b/R/CreateKafkaConsumer.R
new file mode 100644
index 0000000..cf6edee
--- /dev/null
+++ b/R/CreateKafkaConsumer.R
@@ -0,0 +1,11 @@
+CreateKafkaConsumer <- function(kafka.rest.proxy = "http://localhost:8082", consumer, consumer_instance) {
+  response <- POST(url=paste(kafka_rest_proxy, "consumers", consumer, sep="/"),
+                   content_type("application/vnd.kafka.v2+json"),
+                   accept("application/vnd.kafka.v2+json"),
+                   body=paste0('{"name": "',
+                               consumer_instance,
+                               '", "format": "json", "auto.offset.reset": "earliest"}')
+  )
+  consumerDetails <- fromJSON(content(response, "text"))
+  return(consumerDetails)
+}
\ No newline at end of file