Perfect.
Thank you.
From: Luke Chen
Sent: Monday, July 19, 2021 5:37 AM
To: Kafka Users
Subject: Re: Kafka incremental sticky rebalancing.
Hi Mazen,
> can it be because the rebalancing is taking place before the offset
commit request has reached
correct this
> weird behavior/exception.
>
> Thank you.
>
>
> From: Mazen Ezzeddine
> Sent: Saturday, July 17, 2021 2:57 PM
> To: Kafka Users
> Subject: Re: Kafka incremental sticky rebalancing.
>
>
> Please note that recently
ocking commit so can not happen…)
So please give me a hint on why this is happening and how to correct this
weird behavior/exception.
Thank you.
From: Mazen Ezzeddine
Sent: Saturday, July 17, 2021 2:57 PM
To: Kafka Users
Subject: Re: Kafka incremental sticky r
it so can not happen…)
So please give me a hint on why this is happening and how to correct this
weird behavior/exception.
Thank you.
From: Luke Chen
Sent: Tuesday, June 22, 2021 3:58 AM
To: Kafka Users
Subject: Re: Kafka incremental sticky rebalancing.
Hi Ma
uke Chen
> Sent: Monday, June 21, 2021 3:06 PM
> To: Kafka Users
> Subject: Re: Kafka incremental sticky rebalancing.
>
> Hi Mazen,
> Did you auto commit offsets or manually? When do you commit offsets?
>
> Thanks
> Luke
>
> Mazen Ezzeddine 於 2021年6月21日 週一
> 下午7:
incremental sticky rebalancing.
Hi Mazen,
Did you auto commit offsets or manually? When do you commit offsets?
Thanks
Luke
Mazen Ezzeddine 於 2021年6月21日 週一
下午7:42 寫道:
> I am running Kafka on Kubernetes using the Kafka Strimzi operator. I am
> using incremental sticky rebalance strategy by configur
Hi Mazen,
Did you auto commit offsets or manually? When do you commit offsets?
Thanks
Luke
Mazen Ezzeddine 於 2021年6月21日 週一
下午7:42 寫道:
> I am running Kafka on Kubernetes using the Kafka Strimzi operator. I am
> using incremental sticky rebalance strategy by configuring my consumers
> with the fo
I am running Kafka on Kubernetes using the Kafka Strimzi operator. I am using
incremental sticky rebalance strategy by configuring my consumers with the
following:
ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,
org.apache.kafka.clients.consumer.CooperativeStickyAssignor.class.getNam