rkafka.readFromSimpleConsumer | R Documentation |
This function returns one message at a time which are read by a KAFKA Simple Consumer
rkafka.readFromSimpleConsumer(SimpleConsumerObj)
SimpleConsumerObj |
Consumer through which messages were received Required:Mandatory Type:Consumer |
There are two types of KAFKA consumers:High-Level and Simple. This function receives messages using the Simple Consumer. Use caution on deciding to use the Simple Consumer as it doesn't persist offset.The function rkafka.receiveFromSimpleConsumer needs to be executed before running this function
String
Warning:The function rkafka.receiveFromSimpleConsumer needs to be executed before running this function
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)) ## End(Not run)
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.