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
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
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
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
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*
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.