И может быть я неправильно с ней обращаюсь? Для каждой

транзакции создаётся свой Id в виде uuidv4, так же для работы необходимо получать последнее сообщение, поэтому создаётся consumer и админ клиентом получаю offset у топика и выставляю на консьюмере. Консьюмер везде уникальный. Могу сделать что бы использовался один и тот же

12 ответов

32 просмотра

Ничё непонятно. Что значит "надо получать последнее сообщение", а остальные не надо что ли получать ) ? Топиков у вас сколько?

ssch- Автор вопроса
Sergey Bezrukov
Ничё непонятно. Что значит "надо получать последне...

Остальные получают другие консьюмеры. Получить последнее сообщение нужно что бы работал механизм синхронизации. Топиков примерно 50

ssch
Остальные получают другие консьюмеры. Получить пос...

Это очень странно выглядит. То есть вы на каждое сообщение создаёте по консьюмеру?

ssch- Автор вопроса
Sergey Bezrukov
Это очень странно выглядит. То есть вы на каждое с...

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

ssch
Нет. Раз в пол минуты получаю последнее сообщение ...

Раз в полминуты соединяетесь с кафкой указывая какую consumer-group, каждый раз разную?

ssch
Угу

Не делайте так. Консьюмер группа это очень небесплатный в кафке объект.

ssch- Автор вопроса
ssch
А transactionId разный указывать?

Я не знаю что такое transactionId, пардон. Но консьюмер группы нельзя размножать бесконтрольно.

Sergey Bezrukov
Я не знаю что такое transactionId, пардон. Но конс...

А разве транзакция может быть с одним id?

ssch- Автор вопроса
Yuriy
А разве транзакция может быть с одним id?

На вряд ли, поэтому остановлю как есть

Yuriy
А разве транзакция может быть с одним id?

Это не про конкретную транзакцию. Это опция на стороне продюсера , включает работу транзакций в Kafka.

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

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

Ребята, всем привет. Подскажите, пожалуйста, можно ли как-то через бота понять, что этого бота добавили в группу\канал и выдали ему права администратора?
Artem Stormageddon
9
Это переведённый текст с английского. Я не говорю на русском, но могу использовать переводчик Телеграм. Приветствую! Я начинающий веб-разработчик и все еще учусь. В настояще...
𐩱𐩪𐩣𐩱𐩲𐩺𐩡
3
А не хотим ли мы развлечься? 😉 Но так чтобы с пользой для наших профессиональных навыков?? 👨‍🎓👩‍🎓 Предлагаю на октябрь запланировать тестовый запуск новой командной игры "Игр...
Andrii Kurdiumov
2
Привет всем! Почему этот код не срабатывает при добавлении или удалении пользователя из чата? bot.on('chat_member', async (ctx) => { console.log(ctx); }) bot.launch({allo...
Alexander
5
у кого сколько оперативы на базе данных ?
АДИЛЬБЕК
4
Через бот апи возможно получить ID стикерпака? Не ссылку.
Vexylon [АФК до 09.09]
5
Привет Хочу сделать аналог iCloud’а для своих проектов, чтобы пользовательская информация хранилась в облаке, была доступна во всех сервисах, её можно было подсасывать везде)...
Виталий
9
В тг можно спарсить всех кто пишет в группе? Если список участников скрыт
S
3
код Event::listen('cms.page.display', function (&$content, $slug, $page, $html) { if (is_object($content)) { dump($content); } else { dump($s...
Point 111
3
Всем привет. Не понимаю, в чём тут шутка юмора. Убирается только разрешение на send_messages. А send_media_messages остаётся. Как сделать, чтобы оба убирались? await b...
Alexander
2
Карта сайта