Description Usage Arguments Value Author(s) Examples
This functions shuts down the KAFKA consumer
1 | rkafka.closeConsumer(ConsumerObj)
|
ConsumerObj |
ConsumerObj:Consumer through which messages are to be read(Java Object) Required:Mandatory Type:Consumer |
Function doesn't return anything
Shruti Gupta
1 2 3 4 5 | ## Not run:
consumer1=rkafka.createHighConsumer("127.0.0.1:2181")
rkafka.closeHighConsumer(consumer1)
## End(Not run)
|
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.