I'm using kafkajs to connect with the confluent kafka, where I'm randomly getting the error.
The coordinator is not aware of this member: The coordinator is not aware of this member
Now my consumer configuration is
const consumer = this._kafkaInstance.consumer({ groupId, heartbeatInterval: 3000, sessionTimeout: 45000 });
This means Kafka should try to rebalance after 45 seconds. But their error message continues to pop up after some time. My topic has six partitions, and I'm also using six consumers.
This issue seems to pop up in the production environment randomly. Not sure how to reproduce it.
I'm using kafkajs to connect with the confluent kafka, where I'm randomly getting the error.
The coordinator is not aware of this member: The coordinator is not aware of this member
Now my consumer configuration isconst consumer = this._kafkaInstance.consumer({ groupId, heartbeatInterval: 3000, sessionTimeout: 45000 });
This means Kafka should try to rebalance after 45 seconds. But their error message continues to pop up after some time. My topic has six partitions, and I'm also using six consumers.This issue seems to pop up in the production environment randomly. Not sure how to reproduce it.
Environment: