Hello guys,

I am using KafkaProducer (org.apache.kafka.clients.producer.KafkaProducer)
to send messages to Kafka broker. I set BUFFER_MEMORY_CONFIG to some MBs.
If there is a case where we need to shutdown kafka producer when there are
messages in producer's buffer, is there any way to flush these messages to
kafka to prevent event loss? will be calling the close() method do the
trick?

Thank you,

-- 
Muqtafi Akhmad
Software Engineer
Traveloka

Reply via email to