rkafka.createSimpleConsumer | R Documentation |
This function creates the Simple Consumer
rkafka.createSimpleConsumer(kafkaServerURL, kafkaServerPort, connectionTimeOut, kafkaProducerBufferSize, clientId)
kafkaServerURL |
|
kafkaServerPort |
Port number of the KAFKA server Required:Mandatory Type:String |
connectionTimeOut |
Connection Timeout in ms Required:Mandatory Type:String |
kafkaProducerBufferSize |
Buffer size Required:Mandatory Type:String |
clientId |
ID of the client Required:Mandatory Type:String |
There are two types of KAFKA consumers:High-Level and Simple. This function creates the Simple Consumer. Use caution on deciding to use the Simple Consumer as it doesn't persist offset.
Doesn't return anything
Warning: Ensure to run the rkafka.receiveFromSimpleConsumer() function before executing the rkafka.runFromSimpleConsumer() 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") ## End(Not run)
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.