rkafka (version 1.4)

rkafka.receiveFromSimpleConsumer: KAKFA Simple Consumer receiving messages

Description

This function allows the KAKFA Simple Consumer to receive messages from a particular topic. However, this doesn't display the messages. To read the messages, use the rkafka.readFromSimpleConsumer function.

Usage

rkafka.receiveFromSimpleConsumer(SimpleConsumerObj, 
topicName, partition, Offset, msgReadSize)

Value

Nothing

Arguments

SimpleConsumerObj

Simple Consumer object through which messages are to be read Required:Mandatory Type:SimpleConsumer

topicName

Name of the topic from where to read messages Required:Mandatory Type:String

partition

Partition Number Required:Mandatory Type:String

Offset

Offset Number Required:Mandatory Type:String

msgReadSize

Size of the message to be read Required:Mandatory Type:String

Author

Shruti Gupta

Details

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.This function needs to be run before executing the rkafka.readFromSimpleConsumer function

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

if (FALSE) {
consumer1=rkafka.createSimpleConsumer("172.25.1.78","9092","10000","100000","test")
rkafka.receiveFromSimpleConsumer(consumer1,"test","0","0","test-group")
}