Всем привет! Начал изучать кафку, и возникло несколько вопросов. Если это

где-то уже обсуждалось - направьте, пожалуйста.

1. Запускаю простое приложение, которое пишет сообщения в кафку быстрее, чем читает. Версия приложения - 0.1, подхватывается кафкой и присваивается в кач-ве названия консьюмер группы;
2. Останавливаю приложение. Поднимаю его версию до 0.2 и запускаю. Создаётся новая консьюмер группа, а не успевшие попасть в консьюмер сообщения с прошлого раза так и остаются висеть в очереди. В итоге:

consumer group -- state -- overall lag
kafkaapp-v0.1 -- - -- 21585
kafkaapp-v0.2 -- Active -- -

Причина понятна: https://stackoverflow.com/questions/58928487/kafka-consumer-not-consuming-from-beginning
Одно из путей решения - это сбросить оффсет группы. Не заставит ли это кафку законсьюмить сообщения дважды? Но группа kafkaapp-v0.1 уже не в ходу: нужно как-то "перекинуть" сообщения в kafkaapp-v0.2?

Мог ошибиться где-то с терминами. Если так, поправьте. Спасибо!

1 ответов

8 просмотров

Оставить название консьюмер группы прежним можно? То есть не изменять его с версией приложения

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

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

❓ Подскажите как сделать в группе телеги функцию (кнопку) пересылки сообщения где есть нарушение правил? Бот к каждому сообщению (по определенным ключам) добавляет снизу кнопк...
Alexander
4
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
13
Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
Вопрос: Здравствуйте! У меня возникла проблема с использованием плагина Mall в OctoberCMS. Я использую все файлы и компоненты в их исходном виде, без изменений. Однако на стр...
𐩱𐩪𐩣𐩱𐩲𐩺𐩡
8
Как думаете через какой сервис они верифицируют?
inc.
5
Я правильно понимаю что нет способов получить список ожидающих заявок на вступление в группу с помощью бота из mtproto?
Шамиль Прилов
9
Добрый день! Подскажите, каким сборщиком фронта для OctoberCMS кто пользуется? Я имею ввиду сборщики, с которыми можно работать по стандартной схеме директорий октября. Я испо...
Николай Афанасенко
2
На чём в основном щас пишут мини апы? Vuejs?
Goot evening Not everyone
6
Добрый день. Мне посоветовали обратиться к вам в чат за помощью. Ситуация описана на скрине. Как мне сказали, мне на бота навесили флудвейт. Есть ли возможность снять его ра...
OVERLINK
7
🙋 Ребята, всем привет. Поправил задачу: Нужно каждому новому сообщению (1 раз по каждому юзеру) в чате прибавлять снизу кнопку с предложением подписаться на канал. Как добавит...
Alexander
1
Карта сайта