rkafka.read: KAFKA consumer reading messages(single)

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

Description

This function reads messages received by a KAFKA consumer. It fetches one message at a time

Usage

rkafka.read(ConsumerObj)

Arguments

ConsumerObj

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

Details

This function returns one message at a time 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

String

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.read(consumer1)

## End(Not run)

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