rkafka.closeConsumer | R Documentation |
This functions shuts down the KAFKA consumer
rkafka.closeConsumer(ConsumerObj)
ConsumerObj |
ConsumerObj:Consumer through which messages are to be read(Java Object) Required:Mandatory Type:Consumer |
Function doesn't return anything
Shruti Gupta
## Not run: consumer1=rkafka.createHighConsumer("127.0.0.1:2181") rkafka.closeHighConsumer(consumer1) ## End(Not run)
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.