Re: Group Coordinator stuck on PrepareRebalance state.

2019-07-15 Thread Aravind Dongara
Hi Boyang, Our initial assessment was not accurate, but after scanning through all the stream threads on all machines we found that while most of the threads are participating in the joinRequest call some are stuck at TransactionalRequestResult.await() while doing StreamTask.commit(). We think

Re: Doubts in Kafka

2019-07-15 Thread aruna ramachandran
I want to process a single message at a time to avoid duplication. On Mon, Jul 15, 2019 at 9:45 PM Pere Urbón Bayes wrote: > The good question, Aruna, is why would you like to do that? > > -- Pere > > Missatge de aruna ramachandran del dia dl., 15 de > jul. 2019 a les 14:17: > > > Is there a w

Bay area Kafka Meetup hosted by Confluent at Palo Alto, Tuesday 6:30pm, July 16, 2019

2019-07-15 Thread Guozhang Wang
Hello folks, This is just a kind reminder of the Bay Area Kafka® meetup tomorrow, Tuesday 6:30pm, at Confluent's Palo Alto HQ. *RSVP and Register* (if you intend to attend in person): https://www.meetup.com/KafkaBayArea/events/262715611/ please read instructions within the link to register for c

Re: Doubts in Kafka

2019-07-15 Thread Pere Urbón Bayes
The good question, Aruna, is why would you like to do that? -- Pere Missatge de aruna ramachandran del dia dl., 15 de jul. 2019 a les 14:17: > Is there a way to get the Consumer to only read one message at a time and > commit the offset after processing a single message. > -- Pere Urbon-Baye

Re: Doubts in Kafka

2019-07-15 Thread Suman B N
Explore and set max.poll.records. On Mon, Jul 15, 2019 at 5:47 PM aruna ramachandran wrote: > Is there a way to get the Consumer to only read one message at a time and > commit the offset after processing a single message. > -- *Suman* *OlaCabs*

Doubts in Kafka

2019-07-15 Thread aruna ramachandran
Is there a way to get the Consumer to only read one message at a time and commit the offset after processing a single message.