Как сделать каждое сообщение долговечным в кафке
Установите log.flush.interval.messages=1. сброс является асинхронным или синхронным? таким образом, когда клиент-производитель получил подтверждение, это означает, что сообщение является надежным или нет?
1 ответ
Возможно, вам придется редактировать Producer файл свойств в пределах Config папка. Установить request.required.acks в -1 так что это делает производителя надежным и гарантирует, что сообщения не будут потеряны, пока пользователь не подтвердит полученные сообщения.
Вы можете посмотреть на это (в разделе "Настройки производителя") для получения дополнительной информации.