Уменьшить KafkaProducer отправить время асинхронного ответа
Мой Java KafkaProducer способен отправлять сообщения и получать асинхронный обратный вызов в обоих случаях успеха / сбоя должным образом. Всякий раз, когда происходит сбой, в Call back я получаю сообщение "Не удалось обновить метаданные через 60000 мс". т.е. для каждого случая ошибки мне нужно подождать 6000 мс, т.е. 6 секунд. Как я могу уменьшить время отклика? Это настраивается и может быть установлено в свойствах производителя? Затем, какой ключ свойства я должен использовать, чтобы сократить время с 6000 мс до некоторой величины. Я пробовал max.timeout.ms и request.timeout.ms, установленный на 3000 (как в виде строки, так и целого числа. Но это не отражалось.
1 ответ
Failed to update metadata after 60000 ms означает, что клиент не может получить метаданные от брокера (-ов) в течение указанного времени. Если вы хотите уменьшить этот тайм-аут, настройку производителя max.block.ms может быть установлен на более низкое значение.