Я знаю, что могу установить acks=all
в конфигурации производителя Kafka, чтобы производитель ждал подтверждения от лидера после того, как все реплики получат отправленное сообщение.Если происходит тайм-аут подтверждения, производитель повторяет отправку сообщения.Это происходит прозрачно, не требуя никаких изменений кода.Можно ли получить статистику этих попыток?Можно ли узнать, какое сообщение было связано с повторными попытками и сколько попыток.Предоставляет ли Кафка какой-либо перехват, который нужно вызвать до / после повтора, чтобы мы могли записать какое-нибудь сообщение?