Data Engineering and BI courses are free this week!
This function creates the Simple Consumer
rkafka.createSimpleConsumer(kafkaServerURL,
kafkaServerPort, connectionTimeOut,
kafkaProducerBufferSize, clientId)Doesn't return anything
Port number of the KAFKA server Required:Mandatory Type:String
Connection Timeout in ms Required:Mandatory Type:String
Buffer size Required:Mandatory Type:String
ID of the client Required:Mandatory Type:String
Shruti Gupta
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.
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
if (FALSE) {
consumer1=rkafka.createSimpleConsumer("172.25.1.78","9092","10000","100000","test")
}
Run the code above in your browser using DataLab