squah-confluent commented on code in PR #22708:
URL: https://github.com/apache/kafka/pull/22708#discussion_r3500684096
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java:
##########
@@ -334,9 +334,14 @@ public void updateMember(ConsumerGroupMember newMember) {
/**
* Updates the member id stored against the instance id if the member is a
static member.
*
+ * @param oldMember The old member state.
* @param newMember The new member state.
*/
- private void updateStaticMember(ConsumerGroupMember newMember) {
+ private void updateStaticMember(ConsumerGroupMember oldMember,
ConsumerGroupMember newMember) {
+ if (oldMember != null && oldMember.instanceId() != null &&
+ !oldMember.instanceId().equals(newMember.instanceId())) {
Review Comment:
Thanks for the suggestion! I removed the instance id equality checks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
