Цитата из https://www.safaribooksonline.com/libra ... afka_CO2-1
Недостаток заключается в том, что, хотя commitSync() будет повторять попытку фиксации
до тех пор, пока она
не будет успешной или не произойдет невозвратная ошибка, commitAsync()
не будет повторять попытку.
Мне непонятна эта фраза. Я предполагаю, что потребитель отправляет брокеру запрос на фиксацию, и если брокер не отвечает в течение некоторого времени, это означает, что фиксация не удалась. Я ошибаюсь?
Можете ли вы подробно объяснить разницу между commitSync и commitAsync?
Также, пожалуйста предоставить примеры использования, когда какой тип фиксации мне следует предпочесть.
Подробнее здесь: https://stackoverflow.com/questions/465 ... ommitasync
Кафка-потребитель. commitSync против commitAsync ⇐ JAVA
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Кафка потребитель перебалансирован, несмотря на разные групповые идентификаторы
Anonymous » » в форуме Python - 0 Ответы
- 3 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Кафка в последний раз совершает увеличение смещения, даже если потребитель не обрабатывает
Anonymous » » в форуме JAVA - 0 Ответы
- 5 Просмотры
-
Последнее сообщение Anonymous
-