This question is about UNKNOWN_MEMBER_ID issue In fact , we meet the block issue . But we don't have solution to resolve this problem ..
For example : we have one job running on production environment, and consume data . But suddenly , the consumer can not consume message (maybe heartbeat or session timeout). After consumer restart to rejoin group , it cannot join consumer group and keep A lot of LAGs. because of UNKNOWN_MEMBER_ID Because it is production , we can not change group name and re-consume data, we need to use this group name : how can we continue to consume this message with same consumer group ?? where is Member id store (in zookeeper or Kafka)?? Do we have any solution to reset it in the KAFKA server side .For example , remove member id and rejoin it ?? -- Regards, Zhang Chao