уменьшить KafkaProducer отправить время асинхронного ответа - PullRequest
0 голосов
/ 19 декабря 2018

Мой Java KafkaProducer способен отправлять сообщения и получать асинхронный обратный вызов в обоих случаях успеха / сбоя должным образом.Всякий раз, когда происходит сбой, в Callback я получаю сообщение «Не удалось обновить метаданные через 60000 мс».т.е. для каждого случая ошибки мне нужно подождать 6000 мс, т.е. 6 секунд.Как я могу уменьшить время отклика?Это настраивается и может быть установлено в свойствах производителя?Затем, какой ключ свойства я должен использовать, чтобы сократить время с 6000 мс до некоторой величины.Я попытался установить max.timeout.ms и request.timeout.ms на 3000 (как в виде строки, так и целого числа. Но это не отражалось.

1 Ответ

0 голосов
/ 20 декабря 2018

Failed to update metadata after 60000 ms означает, что клиент не может получить метаданные от брокера (-ов) в течение указанного времени.Если вы хотите уменьшить это время ожидания, для конфигурации производителя max.block.ms может быть установлено меньшее значение.

...