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

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

12 ответов

50 просмотров

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

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.

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

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

Добрый вечер, Пока не совсем понимаю как наладить общение между телеграм ботом и ПО для работы с сим боксом. По самому боту так понял: - Нужен некий баланс, который можно поп...
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
Карта сайта