Как request.timeout.ms конфигурации производителя и request.timeout.ms конфигурации брокера играют вместе - PullRequest
Новая
       8

Как request.timeout.ms конфигурации производителя и request.timeout.ms конфигурации брокера играют вместе

2 голосов
/ 13 февраля 2020

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

Producer Configurations:
delivery.timeout.ms = 15000
request.timeout.ms = 10000 
linger.ms = 0
reconnect.backoff.ms = 50

Broker configurations:
request.timeout.ms = 30000

Теперь, если я отправляю сообщение во время t1, а кластер не работает, сколько времени продюсер ждет, прежде чем выдать исключение соединения?

1 Ответ

0 голосов
/ 14 февраля 2020

Я запустил тест и заметил, что send () завершается с ошибкой, за исключением ниже

Не удалось отправить; Вложенное исключение - org. apache .kafka.common.errors.TimeoutException: Topi c test.topi c, отсутствующее в метаданных после 45000 мс

в эти 45000 мс, равно 'max.block .ms'.

...