rkafka.closeConsumer: Closing KAKFA consumer

View source: R/rkafka.R

rkafka.closeConsumerR Documentation

Closing KAKFA consumer

Description

This functions shuts down the KAFKA consumer

Usage

rkafka.closeConsumer(ConsumerObj)

Arguments

ConsumerObj

ConsumerObj:Consumer through which messages are to be read(Java Object) Required:Mandatory Type:Consumer

Value

Function doesn't return anything

Author(s)

Shruti Gupta

Examples

## Not run: 
consumer1=rkafka.createHighConsumer("127.0.0.1:2181")
rkafka.closeHighConsumer(consumer1)

## End(Not run)

rkafka documentation built on Aug. 10, 2022, 5:08 p.m.