Learn R Programming

rkafka (version 1.1)

rkafka.closeConsumer: 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

Examples

Run this code
# NOT RUN {
consumer1=rkafka.createHighConsumer("127.0.0.1:2181")
rkafka.closeHighConsumer(consumer1)
# }

Run the code above in your browser using DataLab