rkafka.closeProducer: KAFKA producer shutdown

View source: R/rkafka.R

rkafka.closeProducerR Documentation

KAFKA producer shutdown

Description

This function closes the KAFKA producer

Usage

rkafka.closeProducer(producer)

Arguments

producer

Producer which is to be terminated Required:Mandatory Type:Producer

Value

Doesn't return anything

Author(s)

Shruti Gupta

Examples

## Not run: 
producer1=rkafka.createProducer("127.0.0.1:9092")
rkafka.closeProducer(producer1)

## End(Not run)

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