Break out DestroyKafkaConsumer function.

[R/project-using-kafka-in-R.git] / kafkaConsumer.R

diff --git a/kafkaConsumer.R b/kafkaConsumer.R
index 6e8fe0bc80dfe76052a2ee87114f5ce1ca6281a5..8b5e6c7f8acee1edb8c53debed53cc37fb002030 100644 (file)
--- a/kafkaConsumer.R
+++ b/kafkaConsumer.R
@@ -51,5 +51,5 @@ apachelog <- rbind(messages$value,messages2$value)
 createPlot(apachelog)
 
 # Remove the consumer
-DELETE(url = consumerDetails$base_uri,
-       content_type("application/vnd.kafka.v2+json"))
+source("R/DestroyKafkaConsumer.R")
+response <- DestroyKafkaConsumer(consumer.base.uri = consumerDetails$base_uri)