Привет! При ошибке produce мы же не можем гарантировать, что

сообщени не записалось в топик?

13 ответов

16 просмотров

можно сделать идемпотентного продюсера и накрутить ретраев

Shaplin-Шаплин Автор вопроса
Yegor
можно сделать идемпотентного продюсера и накрутить...

Но если пришла ошибка, то значит сообщение не записалось в топик? Может ли быть такое, что оно запишется, а сетка между кластером и программой упадет?

Shaplin Шаплин
Но если пришла ошибка, то значит сообщение не запи...

может) для этого и нужно ретраить с идемпотентным продюсером во избежании дублей))

Shaplin Шаплин
Но если пришла ошибка, то значит сообщение не запи...

лучше считать что в любом случае будут дубли, чем полагаться на их отсутствие

Сделайте продесер транзакционным. В кафку он писать будет, но при падении записи откатятся.

Yegor
может) для этого и нужно ретраить с идемпотентным ...

Ни идемпотентный продюсер, ни транзакционный дают исключительно at-least-once, для исключения дублей необходима идемпотентность на уровне консьюмера.

Alexander Fedyukov
Сделайте продесер транзакционным. В кафку он писат...

Транзакция здесь никак не поможет, у нас и так есть ack, транзакция нужна для записи в несколько партиций и гарантий, что они все будут записаны(или ролбэк).

Ilya Starchenko
Транзакция здесь никак не поможет, у нас и так ест...

Что произойдёт с записанными сообщениями, если в момент получения ака у нетранзакционного продюсера выключат свет? А если у транзакционного?

Alexander Fedyukov
Что произойдёт с записанными сообщениями, если в м...

В случае одного сообщения - это идентичные ситуаци(если, конечно, ack и in-sync настроены нормально).

Ilya Starchenko
В случае одного сообщения - это идентичные ситуаци...

Зачем тогда придумали readcommited? Если аков всегда должно хватать.

Alexander Fedyukov
Зачем тогда придумали readcommited? Если аков всег...

Потому что транзакционность необходима для продьюсинга сообщений во множество партиций и получения гарантии, что они все будут записаны(или ролбэк). Но это ничего не дает в случае одного сообщения, так как у нас и так есть механизм ack и так же это не дает exactly-once(так как он теоритически невозможен). P.S. Transactional api в кафке - это самый сложный api, который я видел, и я бы лишний раз подумал, прежде чем его приносить(хотя со своей задачей он, конечно, справляется).

Ilya Starchenko
Потому что транзакционность необходима для продьюс...

Не совсем так. Транзакционный продюсер позволяет также синкать отправку сообщений и коммит оффсета. Что позволяет организовать read process write с exactly once семантикой.

Anatoliy
Не совсем так. Транзакционный продюсер позволяет т...

Это с большой натяжкой можно назвать exactly-once, но да, если мы говорим про reed-process-write(без учета внешних систем), то да, оно имеет подобные свойства, с другой стороны, изначальное сообщение исключительно про продюсера.

Похожие вопросы

Обсуждают сегодня

Добрый вечер, Пока не совсем понимаю как наладить общение между телеграм ботом и ПО для работы с сим боксом. По самому боту так понял: - Нужен некий баланс, который можно поп...
Magic
6
сделал сайт, прикрутил в боте сайт, и виджет логина. как автоматически логинить пользователя в аккаунт(телеграм), при входе с бота?
Александра Чернивецкая
5
Объясните, пожалуйста, почему компилятор ругается на использование в условии неинициализированной переменной: int x; Task.Run(async () => { x = await somefunc(); }).Wait...
Александр
5
Ребят, подскажите, пожалуйста, почему в префиксе к ассетам, которые генерируются через фильтр | theme в шаблоне, стал вдруг появляться index.php? Вот так выглядит ссылка на а...
Виталий
1
Всем привет. Ребята, подскажите, пожалуйста. у ботов есть ограничение на отправку сообщений - 30 сообщений в секунду, эти ограничения накладываются на все сообщения? или на со...
Artem Stormageddon
4
Блин, ребята, сори за тупые вопросы. А можно ли как-то открыть вебапку по нажатию на кнопку в меню(которое появляется слева, команды)?
Artem Stormageddon
3
а плаксы из-под питона умеют только в комфортных условиях что-то выдавить из себя?)
Lencore
9
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
13
Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
Коллеги, может знает кто, можно ли цвет бейджа счётчика в BackendMenu менять без бубнов?
Alex Blaze
3
Карта сайта