? А для producer'a при отсылке сообщения это будет delivery.timeout = request.timeout + linger.timeout верно ? При выставлении данных параметров они передаются на сервер и кафка выставляет таймаут в очереди ? или они только на стороне клиента ?
точно не скажу, но вроде как передаются на сервер и не должны превышать указанных на брокере значений.
Ну я только delivery.timeout уменьшил мне кажется оно только для клиенской время отведеное для всех попыток с лиджером.
такого рода таймауты чисто на стороне клиента. кафка делегирует принятие решений о таймаутах клиенту. на сервере если случился таймаут при ожидании обработки, то вернется ошибка клиенту, т. е. либо раньше клиент отвалится (если его таймаут меньше), либо сераер скажет, что не успел обработать
А если клиент не дождался и делает вторую попытку, порядок гарантирован ?
да, в рамках партиции
А серверные таймауты для записи это где ?
в случае репликации тайматы кворума есть
А можете ткнуть пальцем.
controller.quorum.request.timeout.ms но вы лучше скажите, какую проблему решаете
Я хочу понять вот посылает продюсер данные retries=0, enable.idempotence=false, delivery.timeout.ms=37000(default 2min) они ложатся в очередь на брокере и какой параметер определяет сколько времени пакет с данными будет жить в очереди если кластер развалился или притормозил.
Обсуждают сегодня