Re: Transaction support multiple producer instance

2019-05-31 Thread Sandeep Nemuri
215)> > > > >> > > > at> > > > > org.apache.kafka.clients.producer.KafkaProducer.beginTransaction(KafkaProducer.java:606)> > > > >> > > > at> > > > > com.matt.test.kafka.producer.ProducerTransactionExample.main(ProducerTransactionExample.java:68)> > > > >> > > > Caused by: org.apache.kafka.common.errors.ProducerFencedException:> > > > Producer attempted an operation with an old epoch. Either there is a > newer> > > > producer with the same transactionalId, or the producer's transaction > has> > > > been expired by the broker.> > > >> > > > Please help us how to solve this, Thanks.> > > >> > > > > > > -- > > > Santilli Jonathan> > > > -- * Regards* * Sandeep Nemuri*

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-13 Thread Sandeep Nemuri
;>>> KIP-249 > > >>>>>> < > > >>>>> > > >>>> > > >>> > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-48+Delegation+token+support+for+KafkaKIP-249 > > > > >>>>>> > > >>>>>> : > > >>>>>> > > >>>>>> > > >>>>> > > >>>> > > >>> > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-249%3A+Add+Delegation+Token+Operations+to+KafkaAdminClient > > > > >>>>>> > > >>>>>> He has broad experience working with many of the core components > in > > >>>> Kafka > > >>>>>> and he has reviewed over 80 PRs. He has also made huge progress > > >>>>> addressing > > >>>>>> some of our technical debt. > > >>>>>> > > >>>>>> We appreciate the contributions and we are looking forward to > more. > > >>>>>> Congrats Manikumar! > > >>>>>> > > >>>>>> Jason, on behalf of the Apache Kafka PMC > > >>>>>> > > >>>>> > > >>>> > > >>> > > >> > > >> > > >> -- > > >> Sönke Liebau > > >> Partner > > >> Tel. +49 179 7940878 > > >> OpenCore GmbH & Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany > > > > [attachment "signature.asc" deleted by Edoardo Comar/UK/IBM] > > > > > > Unless stated otherwise above: > > IBM United Kingdom Limited - Registered in England and Wales with number > > 741598. > > Registered office: PO Box 41, North Harbour, Portsmouth, Hampshire PO6 > 3AU > > > -- * Regards* * Sandeep Nemuri*

Re: [ANNOUNCE] New committer: Onur Karaman

2017-11-08 Thread Sandeep Nemuri
> > multiple > > > > deadlocks and race conditions. The latter significantly improved the > > > > performance when there are many partitions. Experimental results show > > > that > > > > Onur's work reduced the controlled shutdown time by a factor of 100 > > times > > > > and the controller failover time by a factor of 3 times. > > > > > > > > Congratulations, Onur! > > > > > > > > Thanks, > > > > > > > > Jun (on behalf of the Apache Kafka PMC) > > > > > > > > > > -- * Regards* * Sandeep Nemuri*

Re: Kafka Configuration Question

2017-05-28 Thread Sandeep Nemuri
; kafka: { version: 0.10.1.1 } > > > > zkper: { version: 3.4.9 } > > > > Conrad Bennett Jr. > > > > > > > -- > Raghav > -- * Regards* * Sandeep Nemuri*

Re: KIP-162: Enable topic deletion by default

2017-05-28 Thread Sandeep Nemuri
> I've added a KIP to improve our out-of-the-box usability a bit: > > KIP-162: Enable topic deletion by default: > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 162+-+Enable+topic+deletion+by+default > > > > > > > Pretty simple :) Discussion and feedback are welcome. > > > > Gwen > > > > > > > > > > > > > > > -- * Regards* * Sandeep Nemuri*

Re: Kafka won't take messages

2017-04-17 Thread Sandeep Nemuri
y to run a Simple Producer, I get the same result. > > Adaryl "Bob" Wakefield, MBA > Principal > Mass Street Analytics, LLC > 913.938.6685 > www.massstreet.net > www.linkedin.com/in/bobwakefieldmba > Twitter: @BobLovesData > > -- * Regards* * Sandeep Nemuri*