<![CDATA[Комментарии / Профиль dm_aq]]> https://habr.com/ru/users/dm_aq/comments/ ru editor@habr.com habr.com Sun, 26 Jul 2026 08:22:46 GMT https://habr.com/ru/ https://habrastorage.org/webt/ym/el/wk/ymelwk3zy1gawz4nkejl_-ammtc.png Хабр 01.08.2021 13:44:17 https://habr.com/ru/articles/570674/#comment_23323262 https://habr.com/ru/articles/570674/#comment_23323262 Да, тут соглашусь, такое может быть. Это пожалуй одна из причин для чего я начал этот цикл статей - немного развеять туман в связке spring + kafka (в том числе и для себя)

]]> Sun, 01 Aug 2021 13:44:17 GMT 01.08.2021 13:19:48 https://habr.com/ru/articles/570674/#comment_23323180 https://habr.com/ru/articles/570674/#comment_23323180

События "данные обработаны" и "commit" происходят независимо друг от друга.

Почему вы так решили? В случае если мы не берём управление коммитом на себя и оставляем enable.auto.commit=true делегируя тем самым коммит KafkaConsumer последовательность вполне детерминирована :

  1. Закоммитили предыдущий оффсет

  2. Получили новые сообщения

  3. Обработали

Если мы сознательно не выносим последний шаг в отдельный поток

]]> Sun, 01 Aug 2021 13:19:48 GMT 01.08.2021 12:49:22 https://habr.com/ru/articles/570674/#comment_23323066 https://habr.com/ru/articles/570674/#comment_23323066 Тут опять же все зависит от того как вы спроектируете обработку. В данном случае consumer и listener выполняются в одном потоке. Если вы отделяете обработку в отдельный поток, то и менеджмент коммитов остаётся на вашей совести. Собственно так и поступает spring-kafka при enable.auto.commit=false.

]]> Sun, 01 Aug 2021 12:49:22 GMT 01.08.2021 04:33:21 https://habr.com/ru/articles/570674/#comment_23322070 https://habr.com/ru/articles/570674/#comment_23322070 Почему не гарантируется? Все зависит от того как мы работаем с исключительными ситуациями , если используем обработчики ошибок по-умолчанию - то да, вы правы.

Тут важно отметить один момент про который я писал в первой статье: при включённой настройке enable.auto.commit=true коммит не происходит сам по себе, а жестко связан с получением сообщения.

Т.е. последовательность в цикле обработки сообщений у нас получается такая:

  1. Коммитим предыдущее смещение

  2. Получаем новые сообщения

  3. Обрабатываем

]]> Sun, 01 Aug 2021 04:33:21 GMT 20.05.2021 06:43:42 https://habr.com/ru/articles/558206/#comment_23056262 https://habr.com/ru/articles/558206/#comment_23056262 commitAsync() / commitSync(), которые можно дергать руками (там есть возможность либо передать в аргуметны конкретный offset либо будет использован последний полученный при вызове poll())
Но если мы сами ничего руками не вызываем (в том числе и метод poll() для получения новых сообщений), то ничего само отправляться не будет.]]> Thu, 20 May 2021 06:43:42 GMT