Confluent Kafka Consumer Configuration - Как связаны сессии.timeout.ms и max.poll.interval.ms? - PullRequest
1 голос
/ 22 октября 2019

Я пытаюсь понять, как значения по умолчанию для следующих двух слитых конфигураций потребителя работают вместе.

max.poll.interval.ms - В соответствии с документацией слияния значение по умолчанию составляет 300 000 мс

session.timeout.ms - в соответствии со стандартной документацией значение по умолчанию составляет 10000 мс

heartbeat.interval.ms - в соответствии со стандартной документацией значение по умолчанию составляет 3000 мс

Давайтескажем, если я использую эти значения по умолчанию в моей конфигурации. Теперь у меня есть вопрос здесь.

Например, предположим, что для потребителя потребитель отправляет тактовые импульсы каждые 3000 мс, а мой первый опрос произошел на отметке времени t1, а затем второй опрос произошел в момент времени t1 + 20,00 мс. Тогда это вызвало бы перебалансировку, потому что это превышает "session.timeout.ms"? или он будет работать нормально, так как потребитель отправил сердцебиение в соответствии с ожидаемой отметкой времени?

...