да, сокеты. хартбиты тоже есть

Хуясе вы там продвинутые

фраху ставь. ещё лучше Дарвин... потом к нему иксы прикрутишь, они довольно стильные)

Фряха стоит на пс4, дарвин мб в айфоне, пройденный этап)

Фряха стоит на пс4, дарвин мб в айфоне, пройденный этап)

Зачем первое сделал

Смисле?

Так сони придумал, я просто пользуюсь

Ну там мягко говоря не просто фряха

А фрибзд они взяли наверное потому что там лицензия не пидорская

Ну там мягко говоря не просто фряха

Ну таки фряха же

Ну таки фряха же

На комп поставитьфряху и играть в игры от Сони сможешь?

Нативно

На комп поставитьфряху и играть в игры от Сони сможешь?

Я не понимаю о чем мы спорим!

Ну с другой стороны когда это мешало

Я не понимаю о чем мы спорим!

Я про то что там давно не фряха уже о которой ты говоришь

А основана на фряхе может означать что ее на 99% перелопатили

Ну я и андроид приложения просто так на линуксе не запущу

Хотя казалось бы

Я не понимаю о чем мы спорим!

Разве это важно? Главное спор 😂😅

Ну я и андроид приложения просто так на линуксе не запущу

Погоди а Самсунг декс?

Земля ему пухом

Погоди а Самсунг декс?

Сосунг проприетарная какая-то шляпа, мало ли извращенцев)

Сосунг проприетарная какая-то шляпа, мало ли извращенцев)

То же самое что и сони ))0

Проприетарная шляпа

Так для людей зато

Включил и погнали

Не могу сказать того же самого про десктоп осс ос!

Кстати, если дефолтные настройки, то второй нихуя не получит именно потому что нет ни одного коммита, а по умолчанию в отсутствии коммита читается с конца стрима

а в пульсаре кстати эта настройка умная - ты можешь выбрать с конца стрима читать, но это только для старта консьюминга, потом если консьюмер отвалился и перезапустился, он прочитает оттуда откуда закончил

Не могу сказать того же самого про десктоп осс ос!

Тут не могут Винду так же сделать!

а в пульсаре кстати эта настройка умная - ты можешь выбрать с конца стрима читать, но это только для старта консьюминга, потом если консьюмер отвалился и перезапустился, он прочитает оттуда откуда закончил

А как он узнает откуда он закончил?

Тут не могут Винду так же сделать!

На иксбоксе винда заебись вроде работает, видимо когда вендор сразу комплекс продаёт что-то в этом есть

там подписки - аналог консьюмер группы. И эта подписка хранится и апдейтится после коммитов

а в пульсаре кстати эта настройка умная - ты можешь выбрать с конца стрима читать, но это только для старта консьюминга, потом если консьюмер отвалился и перезапустился, он прочитает оттуда откуда закончил

Тогда я не понял в чём разница

То есть чтение с начала стрима или с конца она для случая отсутствия коммита - старта консуминга Далее с комита продолжается после отвала

аа, тогда непонятно почему ты написал что второй нихуя не получит если чтение с конца стрима)

аа, тогда непонятно почему ты написал что второй нихуя не получит если чтение с конца стрима)

Потому что по умолчанию настройка стоит - читаем с конца стрима в отсутствии комита в метадате. Твой сценарий был что есть один консумер, ему продьюсят 2 месаджа, он их не комитит, приходит 2ой консумер, что он получит? Ничего на дефолтных настройках

аа, понял) ну я имел ввиду не этот корнеркейс, а просто случай посреди стрима)

К слову, в кафке всегда можно прочитать метадату по топику и выставить свой офсет хардкорно и начать читать с него через seekOffset, но это продвинутый сценарий

Через нее можно что угодно сделать

ну нет, ты не можешь в кафке сделать поведение пульсара) правда как и наоборот)

ну нет, ты не можешь в кафке сделать поведение пульсара) правда как и наоборот)

Если бы я знал особенности пульсара!

то что второму консьюмеру не приходит сообщение пока первый не закоммитит)

т.е. в кафке тебе надо выбирать или двойную обработку или потерю сообщения

Всем привет Помогите пожалуйста с выбором Я не особо люблю делать сайты Но мне нравится делать прилажения на пк и мобилу Что лучше выбрать шарм или джаву И что получить что бы получить первый офер?) Спасибо за ответ

@omgszer там в фиолетовом опять приколы

Всем привет Помогите пожалуйста с выбором Я не особо люблю делать сайты Но мне нравится делать прилажения на пк и мобилу Что лучше выбрать шарм или джаву И что получить что бы получить первый офер?) Спасибо за ответ

шаурму

т.е. в кафке тебе надо выбирать или двойную обработку или потерю сообщения

В пульсаре я вижу то же самое. По итогу, если первый отпроцессил сообщения и умер до комита, чтение задублируется

@omgszer там в фиолетовом опять приколы

Неплохо!

В пульсаре я вижу то же самое. По итогу, если первый отпроцессил сообщения и умер до комита, чтение задублируется

не, ты тогда знаешь что первый не закоммтил его. В кафке ты получается счастливо сделаешь коммит из обоих консьюмеров и знать ничего не будешь что был дубликат

не, ты тогда знаешь что первый не закоммтил его. В кафке ты получается счастливо сделаешь коммит из обоих консьюмеров и знать ничего не будешь что был дубликат

Ты можешь прочитать метадату из топика и узнать что current_offset в группе больше чем current_commited

То есть инфа у тебя эта имеется)

Current_offset меняется каждый раз когда из партишна сервят инфу консумерам. То есть это последний посланный офсет

Ты можешь выставить чтение с current_offset парой строчек при подключении чтобы имитировать пульсар видимо

Но я именно таким не занимался. Сбрасывал оффсеты всем в группе - это да. Даже тула была в джете чтобы пойзон месаджи от дебилов скипать

Ты можешь выставить чтение с current_offset парой строчек при подключении чтобы имитировать пульсар видимо

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

ну впринципе в лупе это проделывать разве что)

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

Я видимо нихуя за пульсар не понял)

ладно, оставим это) пора пылесосить)

+

Привет! Кто может за кафку пояснить? Есть два партишна и сначала один консьюмер, продьюсятся два сообщения, каждое попадает в свой партишн и консьюмеру, он их берет, но оффсеты не коммитит еще, потом коннектится еще один консьюмер в ту же консьюмер группу, на него назначается один из партишнов. Вопрос - он тут же получит незакоммиченное сообщение? И получится что оба консьюмера его обработали?

В Кафке есть транзакционность на коленках, если такое поведение не подходит, то можно (но нужно ли?) использовать транзакции.

Но транзакции и Кафка это уж с ежом, не иначе.

А кто нибудь юзал стримы редиса?🤔

В Кафке есть транзакционность на коленках, если такое поведение не подходит, то можно (но нужно ли?) использовать транзакции.

там прикол есть что в конкурентные транзакции нельзя в кафке) только одна в один момент времени. В пульсаре конечно такого нету ограничения

там прикол есть что в конкурентные транзакции нельзя в кафке) только одна в один момент времени. В пульсаре конечно такого нету ограничения

У транзакции есть transaction_id уникальный для продьюсера

Для этого айди трекается все отдельно

Поэтому можно в конкурентные транзакции в пределах одной группы

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

или для одного консьюмера, точно помню что что-то нельзя)

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

Нельзя да, т.к. транзакшн айди в свойствах подключения задаётся

ну вот

там прикол есть что в конкурентные транзакции нельзя в кафке) только одна в один момент времени. В пульсаре конечно такого нету ограничения

Так стриминг и транзакции это как-то вообще не то, что надо вместе смешивать.

ну почему, ты можешь хотеть и стриминг и exactly once

ну почему, ты можешь хотеть и стриминг и exactly once

Это крайне крайне крайне плохая идея, желательно ее избегать как только можно.

непонятно почему плохая идея)

может ты имел ввиду что имплементация в кафке плохая?

так то флинк exactly once тоже поддерживает

непонятно почему плохая идея)

Плохая потому что это очень жёсткое ограничение, которое было и будет теоретически невозможным (да, все имплементации в определённых непопулярных ситуациях эту гарантию нарушают). Гораздо правильнее, и во многих смыслах дешевле — это выстраивать идемпотентную систему, а все, что касается «строго один раз» жестко ограничить закаленной боями транзакционной системой типа Постгрес и выполнять транзакции с уровнем serializable.

не думаю что "выстроить идемпотентную систему" дешевле чем воспользоваться встроенной возможностью инструмента

не думаю что "выстроить идемпотентную систему" дешевле чем воспользоваться встроенной возможностью инструмента

Ну если вся твоя система это только Кафка и ты готов поручиться, что других механизмов коммуникации не будет (в том числе по http), то да.

Во всех остальных случаях эта гарантия должна соблюдаться всеми звеньями.

В итоге оно всё настраивается быстро, само обновляется через apt тот же, который по-человечески из коробки идёт. В винде целый зоопарк из своего нового пакетного менеджера, приложений из магазина, приложений из инсталлеров

в убунте еще как минимум snap

в убунте еще как минимум snap

Snap кстати местами ощутимо приятнее, так как (пытается) изолировать аппликейшены.