rkafka.closeSimpleConsumer | R Documentation |
This functions shuts down the KAFKA Simple consumer
rkafka.closeSimpleConsumer(SimpleConsumer)
SimpleConsumer |
SimpleConsumer:SimpleConsumer that has to be shut down Required:Mandatory Type:SimpleConsumer |
There are two types of KAFKA consumers:High-Level and Simple.This function shuts down the KAFKA Simple Consumer
Function doesn't return anything
Shruti Gupta
To know when to use simple consumer and when to use High-level Consumer, refer the url below: https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
## Not run: consumer1=rkafka.createSimpleConsumer("172.25.1.78","9092","10000","100000","test") rkafka.receiveFromSimpleConsumer(consumer1,"test","0","0","test-group") print(rkafka.readFromSimpleConsumer(consumer1)) rkafka.closeSimpleConsumer(consumer1) ## End(Not run)
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.