search

tulios / kafkajs

A modern Apache Kafka client for node.js
https://kafka.js.org
MIT License
3.76k stars 528 forks source link

Kafka heartbeat & rebalancing issue #1566

Open samia-invozone opened 1 year ago

samia-invozone commented 1 year ago

How can I fix the below errors? However, I tried to put these values in the consumer config but it didn't work for me.

consumer: { groupId: 'bucket-file-consumer', sessionTimeout: 30000, heartbeatInterval: 3000, },

Screenshot 2023-04-28 at 12 17 20 PM
mgerylrm commented 1 year ago

I thinks i'm facing the same issue due to the default RoundRobin strategy

mdmuhtasimfuadfahim commented 1 year ago

Hi @samia-invozone. Did you get any solution of this problem?

thiagoanselmo commented 1 year ago

I have the same issue

dasaripravin-developer commented 1 year ago

I am facing the same issue, Anyone have a solution?

akospaska commented 5 months ago

Same here

maksym-opanasenko-ft commented 3 weeks ago

We had the same issue. The code to reproduce: https://github.com/maksym-opanasenko/kafkajs-constant-rebalancing/blob/main/ingex.js The workaround: https://github.com/maksym-opanasenko/kafkajs-constant-rebalancing/blob/main/indexPatched.js

In our case, when running multiple consumers, they triggered the rebalancing loop. The details are in this issue: #1720