Nikita Ryanov

Привет! Есть kafka streams приложение, которое читает 3 топика и сохраняет значения в local state (+ каждый local state сохраняет свое состояние в changelog топик). У всех то...

Привет! Подскажите по поводу scodec -- это я не умею его готовить или изначально не стоит ждать от него скорости [де]сериализации? Суть проблемы: есть протокол общения с тара...

Вот судя по логу, должно быть даже не 2, а 4) При reasign partition 4 брокера указывали для партиции или целенаправленно два только оставляли? Возможно, под > нужно чтобы ми...

Я в целом тоже не спец по бенчмаркам =) Хм, странно. А точно 42М вышло? У меня scodec больше 5М не выдает, а вот с джавовым кодеком вышло 33М без доп настроек и с максимально ...

А какой интерфейс для селекта был бы удобнее? Я рассматривал еще варианты вида: select(space, index, key) .withIterator(...) .withLimit() .withOffset() или select(space, ...

Вынести фильтр в виде shared сущности? В процессоре получать текущй фильтр, через контроллер сетить на новый. Выглядит как feature-toggle. Но сама задумка не ясна, так как что...

Поделитесь, кто как добавляет swagger-ui в проект (на finch, http4s и т.п.): в виде полноценного эндпоинта с ui или наружу выставляете только yaml/json доку, а сам ui - отдель...

Добрый день! Есть задача сохранять данные из топика в файл. Хочу использовать для этого Kafka connect file sink. Возник только один вопрос: можно ли настроить синк так, чтобы ...

Если бы было возможно одну и ту же схему под разными ид использовать, то как тогда продюсеру понять, какой ид схемы использовать? То же самое и для консюмера - если для него э...

Подскажите, пожалуйста, почему тарантул упорно говорит, что field не может быть null, если это поле является частью вторичного индекса, типа TREE? Создаю так: box.space.{space...

Привет всем! Такой вопрос: как получить только те поля, которые являются частями индекса? При таком запросе: k, v in box.space[id].index.primary:pairs(....) в переменную v за...

Не совсем вас понял. Я руководствовался этой строкой из доков: box.space.tester:create_index('I',{unique=true,parts={{2,'number',is_nullable=true}}}). При создании схемы, если...

Здравствуйте! А не подскажете, как можно обновить значение первичного ключа строки? Или такое в принципе нельзя сделать без предварительного удаления строки и записи ее заново...

А чем все-таки плох вариант с бд и каким-нибудь Kafka-jdbc или даже debezium, как уже предлагали выше?

Чем тогда запись в один файл будет отличаться от записи в аппенд онли таблицу?

Привет! Не планируете ли обновить docker образ тарантула и включить туда модуль vshard вместо shard?

А после нее?

В чем здесь принципиальная разница?

Правильно даже не то, как он себя должен вести, а то, правильно ли такое допускать?

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