rkafka.closeSimpleConsumer: Closing KAKFA Simple consumer

Description Usage Arguments Details Value Author(s) References Examples

Description

This functions shuts down the KAFKA Simple consumer

Usage

1

Arguments

SimpleConsumer

SimpleConsumer:SimpleConsumer that has to be shut down Required:Mandatory Type:SimpleConsumer

Details

There are two types of KAFKA consumers:High-Level and Simple.This function shuts down the KAFKA Simple Consumer

Value

Function doesn't return anything

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

Examples

1
2
3
4
5
6
7
## Not run: 
consumer1=rkafka.createSimpleConsumer("172.25.1.78","9092","10000","100000","test")
rkafka.receiveFromSimpleConsumer(consumer1,"test","0","0","test-group")
print(rkafka.readFromSimpleConsumer(consumer1))
rkafka.closeSimpleConsumer(consumer1)

## End(Not run)

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