Hello Gwen, Currently I am using 0.8.2, is it recommended to upgrade to 0.9.0? does it will backward compatible to 0.8.2 brokers? Is there any way to 'recover' buffered messages in case there is exception when calling the close() method?
Thank you, On Thu, Nov 26, 2015 at 8:26 AM, Gwen Shapira <g...@confluent.io> wrote: > In 0.9.0, close() has a timeout parameter that allows specifying how long > to wait for the in-flight messages to complete (definition of complete > depends on value of "acks" parameter). > > On Wed, Nov 25, 2015 at 3:58 AM, Muqtafi Akhmad <muqt...@traveloka.com> > wrote: > > > 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 > > > -- Muqtafi Akhmad Software Engineer Traveloka
