Fwd: Is committing offset required for Consumer

2020-05-07 Thread Boyuan Zhang
Add dev mailing list as well. Thanks for your help! -- Forwarded message - From: Boyuan Zhang Date: Thu, May 7, 2020 at 3:51 PM Subject: Is committing offset required for Consumer To: Hi team, I'm building an application which uses Kafka Consumer APIs to read messages

How does a consumer know the given partition is removed?

2021-01-06 Thread Boyuan Zhang
Hi team, I'm working on a long run application, which uses the Kafka Consumer API to poll messages from a given topic and partition. I'm assigning the topic and partition manually by using consumer.assign() API and polling messages by using consumer.poll(). One common scenario for my application

Re: How does a consumer know the given partition is removed?

2021-01-07 Thread Boyuan Zhang
avadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html > > > > Thanks. > > Luke > > > > On Thu, Jan 7, 2021 at 8:45 AM Boyuan Zhang wrote: > > > >> Hi team, > >> > >> I'm working on a long run application, which uses t