Может есть какие то еще варианты реализации этого? И какие

возможны траблы при хранении офсетов снаружи?

2 ответов

9 просмотров

Вот у akka projections есть такие сценарии https://doc.akka.io/docs/akka-projection/current/kafka.html#committing-offset-outside-kafka если я правильно вопрос понял

никаких проблем нету, сортируете стрим окном, трекаете офсет для каждой партиции на етом все и атомарно пишете макс офсет для месаджа в батче для определенной партиции

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

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

Привет, коллеги! Возникла задача ограничить максимальный размер вложений для определённых расширений, например, чтобы для изображений лимит был 10 МБ, а для видео — 100 МБ. Ог...
Andro
1
Всем здравствуйте, Я использую LibUsbDotNet, пытаясь написать библиотека (под linux/Mac OS) для взаимодействия с usb-устройством, который отправляет текст на дисплей покупат...
Асылбек Анарбай
2
Народ, есть у кого идеи или примеры как привязать softDelete трейт к модели файла или были случаи пропажи фоток? На проекте рандомным образом, со слов клиента, пропали фотки у...
XAKFULL XAKEROVICH
3
или как тут карму плюсануть?
XAKFULL XAKEROVICH
3
Это переведённый текст с английского. Я не говорю на русском, но могу использовать переводчик Телеграм. Приветствую! Я начинающий веб-разработчик и все еще учусь. В настояще...
𐩱𐩪𐩣𐩱𐩲𐩺𐩡
3
Ребята, всем привет. Подскажите, пожалуйста, можно ли как-то через бота понять, что этого бота добавили в группу\канал и выдали ему права администратора?
Artem Stormageddon
9
Парни, в 3 версии октября кто сталкивался с тем что System\Models\SettingModel не сохраняет данные настроек в админке?
Эд
5
А не хотим ли мы развлечься? 😉 Но так чтобы с пользой для наших профессиональных навыков?? 👨‍🎓👩‍🎓 Предлагаю на октябрь запланировать тестовый запуск новой командной игры "Игр...
Andrii Kurdiumov
2
всем привет. кто то использовал https://octobercms.com/plugin/inherent-campus ?
Юрий Татаркин
2
Ночной вопрос остался в силе. Кто-нибудь может подсказать как preview fields расширить в Rainlab.User?
Даниил
3
Карта сайта