powered by
This functions shuts down the KAFKA consumer
rkafka.closeConsumer(ConsumerObj)
ConsumerObj:Consumer through which messages are to be read(Java Object) Required:Mandatory Type:Consumer
Function doesn't return anything
# NOT RUN { consumer1=rkafka.createHighConsumer("127.0.0.1:2181") rkafka.closeHighConsumer(consumer1) # }
Run the code above in your browser using DataLab