Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-15687

Update host address for the GoupMetadata when replace static members

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 3.6.0
    • None
    • group-coordinator
    • None

    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?

       

      Attachments

        Issue Links

          Activity

            People

              LucentWong Yu Wang
              LucentWong Yu Wang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: