[KAFKA-15687] Update host address for the GoupMetadata when replace static members

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 3.6.0
• Component/s: group-coordinator
• Assignee: Yu Wang
• Reporter: Yu Wang
• Created: 26/Oct/23 10:46
• Updated: 30/Oct/23 08:39

Description

We are trying to use static membership protocol for our consumers in Kubernetes. When our pod was recreated, we found that the host address in the group description will not change to the address of the new created pod.

For example we have one pod with group.instance.id = id1 and ip = 192.168.0.1 when the pod crashes, we will replace it with a new pod with same group.instance.id = id1 but a different ip = 192.168.0.2. After the new pod joined in the consumer group, with the command "describe group", we found the host is still 192.168.0.1. This makes us cannot find correct consumer instance when check the issue.

After read the source code, we found that the groupCoordinator will not change the host address for the same groupInstanceId.

https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala#L316

Is it also possible to replace the host address when replace the static member?

 

Issue Links

• links to: GitHub Pull Request #14666