Last data update: 2014.03.03
|
R: Closing KAKFA Simple consumer
rkafka.closeSimpleConsumer | R Documentation |
Closing KAKFA Simple consumer
Description
This functions shuts down the KAFKA Simple consumer
Usage
rkafka.closeSimpleConsumer(SimpleConsumer)
Arguments
SimpleConsumer |
SimpleConsumer:SimpleConsumer that has to be shut down
Required:Mandatory
Type:SimpleConsumer
|
Details
There are two types of KAFKA consumers:High-Level and Simple.This function shuts down the KAFKA Simple Consumer
Value
Function doesn't return anything
Author(s)
Shruti Gupta
References
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
Examples
## 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)
Results
|