rkafka.readPoll: KAFKA consumer reading messages(batch)

In shrutigupta23/rkafka: Using Apache 'Kafka' Messaging Queue Through 'R'

Description

This function reads messages received by a KAFKA consumer. It returns a batch of messages

Usage

rkafka.readPoll(ConsumerObj)

Arguments

ConsumerObj

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

Details

This function returns messages as a batch from the topic to which the consumer is associated. If no new message is found with 'x' time(set by ConsumerTimeoutMs property), then it returns ""

Value

Array of Strings

Note

Warning: Ensure to close the consumer after reading messages. Won't work correctly next time otherwise

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

To know how to use a high level consumer refer this: https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example

Examples

## Not run: 

consumer1=rkafka.createConsumer("127.0.0.1:2181","test123")
print(rkafka.readPoll(consumer1)

## End(Not run)

shrutigupta23/rkafka documentation built on May 29, 2019, 9:36 a.m.