Pull to refresh

Comments 2

а если мы НЕ получаем новых сообщений из топика, то и коммит не отправляем?
тут зависит от того как мы работаем с KafkaConsumer. У него есть отдельные методы commitAsync() / commitSync(), которые можно дергать руками (там есть возможность либо передать в аргуметны конкретный offset либо будет использован последний полученный при вызове poll())
Но если мы сами ничего руками не вызываем (в том числе и метод poll() для получения новых сообщений), то ничего само отправляться не будет.
Sign up to leave a comment.

Articles