powered by
This function closes the KAFKA producer
rkafka.closeProducer(producer)
Producer which is to be terminated Required:Mandatory Type:Producer
Doesn't return anything
# NOT RUN { producer1=rkafka.createProducer("127.0.0.1:9092") rkafka.closeProducer(producer1) # }
Run the code above in your browser using DataLab