X-Git-Url: http://git.vanrenterghem.biz/R/project-using-kafka-in-R.git/blobdiff_plain/0ce8ac9c84fc8a3f79d46469a9c3c37232bb62f5..5b2ed10b2cd8f0326a38e9658a3d5cecf2849c6e:/R/SubscribeKafkaTopic.R

diff --git a/R/SubscribeKafkaTopic.R b/R/SubscribeKafkaTopic.R
new file mode 100644
index 0000000..5e6976b
--- /dev/null
+++ b/R/SubscribeKafkaTopic.R
@@ -0,0 +1,12 @@
+SubscribeKafkaTopic <- function(consumer.base.uri, topic) {
+  response <- POST(url=paste(consumer.base.uri,
+                             "subscription", sep="/"),
+                   content_type("application/vnd.kafka.v2+json"),
+                   body = paste0('{"topics":["',
+                                 topic,
+                                 '"]}')
+  )
+  if(response$status_code == 204) {
+    return(response)
+  } else stop(response)
+}
\ No newline at end of file