Когда только один потребитель присутствует в группе и считает, что потребитель не может опросить в пределах session.time.out, тогда будет запущена перебалансировка, но в этом сценарии у нас есть только один потребитель в группе, теперь допустим, session.time. out составляет 30 секунд, а опросы потребителей через 50 секунд будут координатор группы распознает потребителя через 50 секунд и позволит ему зафиксировать смещение или координатор отключит потребителя и нет смещение фиксируется и перебалансирует потребителя с новым идентификатором потребителя? Если последнее зафиксированное смещение было 345678, и в следующем опросе он обработал сообщения до 345900, но потребовалось 50 секунд (session.time.out - 30), то после перебалансировки запускается, будет ли он читать с 345678 или с 345900, или он будет начинаться с auto.offset.reset: последнее смещение
Kafka Consumer перебалансирует только с одним потребителем в группе
Ответы (1)
Количество потребителей не меняет того, как координаторы узнают их. Если потребитель не опрашивает session.timeout.ms, это означает, что он уже превысил heartbeat.interval.ms, поэтому будет запущен перебаланс, и когда потребитель снова опрашивает через 50 секунд, он будет рассматриваться как новый потребитель и ему будет назначен новый идентификатор потребителя.
person
subzero
schedule
24.10.2017
