]> git.vanrenterghem.biz Git - R/project-using-kafka-in-R.git/commitdiff
Document SubscribeKafkaTopic function. master
authorFrederik Vanrenterghem <frederik@vanrenterghem.io>
Fri, 14 Sep 2018 13:33:36 +0000 (21:33 +0800)
committerFrederik Vanrenterghem <frederik@vanrenterghem.io>
Fri, 14 Sep 2018 13:33:36 +0000 (21:33 +0800)
* Add documentation to SubscribeKafkaTopic function.
* Fix typo in CreateKafkaConsumer documentation.

R/CreateKafkaConsumer.R
R/SubscribeKafkaTopic.R

index 71f9f729eebe8ea40d76c9f7d3c431dcb3d01c3d..ae9abf0ea49a125151a1e0d3707a25ab4206ba8e 100644 (file)
@@ -1,6 +1,6 @@
 #' Create Apache Kafka consumer using Confluent's REST Proxy API
 #' 
 #' Create Apache Kafka consumer using Confluent's REST Proxy API
 #' 
-#' \code{CreateKafkaConsumer} creates an Apache Kafka consumer using the rest proxy api provided by Confluence.
+#' \code{CreateKafkaConsumer} creates an Apache Kafka consumer using the rest proxy api provided by Confluent.
 #' 
 #' @param kafka.rest.proxy The URI of the REST Proxy. Defaults to \url{http://localhost:8082}.
 #' @param consumer A chr object with the name for the consumer.
 #' 
 #' @param kafka.rest.proxy The URI of the REST Proxy. Defaults to \url{http://localhost:8082}.
 #' @param consumer A chr object with the name for the consumer.
index 5e6976b64aa94f049f8766e48a2b427f667ce770..8ca0f6240f7394b651d33ade93de3cfac492e13f 100644 (file)
@@ -1,3 +1,14 @@
+#' Subscribe Apache Kafka consumer to a topic using Confluent's REST Proxy API
+#' 
+#' \code{SubscribeKafkaTopic} subscribes an Apache Kafka consumer to a topic 
+#'   using the rest proxy api provided by Confluent.
+#' 
+#' @param consumer.base.uri The URI of the consumer created by \code{\link{CreateKafkaConsumer}}.
+#' @param topic A chr object with the topic to subscribe to.
+#' 
+#' @return If the operation succeeds, returns the response, which can be discarded.
+#'   If the operation fails, it might help out understanding what happened.
+#'   
 SubscribeKafkaTopic <- function(consumer.base.uri, topic) {
   response <- POST(url=paste(consumer.base.uri,
                              "subscription", sep="/"),
 SubscribeKafkaTopic <- function(consumer.base.uri, topic) {
   response <- POST(url=paste(consumer.base.uri,
                              "subscription", sep="/"),