rkafka.closeConsumer

This functions shuts down the KAFKA consumer

 ~kafka 

 ~consumer 

 ~close 

Apache 'Kafka' is an open-source message broker project developed by the Apache Software Foundation which can be thought of as a distributed, partitioned, replicated commit log service.At a high level, producers send messages over the network to the 'Kafka' cluster which in turn serves them up to consumers.See <https://kafka.apache.org/> for more information.Functions included in this package enable:1.Creating 'Kafka' producer 2.Writing messages to a topic 3.Closing 'Kafka' producer 4.Creating 'Kafka' consumer 5.Reading messages from a topic 6.Closing 'Kafka' consumer. The jars required for this package are included in a separate package 'rkafkajars'.

Shruti Gupta

rkafka

Using Apache 'Kafka' Messaging Queue Through 'R'

rkafka.closeConsumer function

<dl> <dt>ConsumerObj</dt>
<dd>ConsumerObj:Consumer through which messages are to be read(Java Object)	
Required:Mandatory
Type:Consumer</dd></dl>

Arguments

Author

Closing KAKFA consumer — rkafka.closeConsumer

<dl>

 <dt>ConsumerObj</dt>
<dd>ConsumerObj:Consumer through which messages are to be read(Java Object)	
Required:Mandatory
Type:Consumer</dd>

</dl>

rkafka.closeConsumer: Closing KAKFA consumer

Description

Usage

Value

Arguments

Author

Examples