Petr O.

А такой вопрос - реальна ли ситуация, что консюмер начнет читать с earliest на грани с ttl сообщений, и перед вторым poll сработает ретеншен, который заденет так же данные кот...

А как можно отслеживать актуальность топика - когда в него последний раз писали? Из идей только по ts последнего сообщения(которого может не быть из за retention) и отслеживат...

А для ksql без confluent control center, чем вы для разработки пользуетесь ? Консоль это конечно хорошо, но от всяких ui не отказались бы)

А подскажите зачем schema-registry подключается к самой кафке ? The Kafka cluster containing the bootstrap servers specified in kafkastore.bootstrap.servers is used to coordi...

ну он не закомитит оффсет сообщений если упадет с ошибкой, не ?

И в целом в юайках не видел поддержки интерактивного запроса - типа обязательно нужно указывать limit, в hue так же ?

подскажите может ли быть сокральный смысл при N партиций в запуске 3*N консюмеров на 3 разных машинах? Верно понимаю, что первые N запущенных будут читать, а все остальные жда...

Можете подсказать по CreateMode для znode - вот есть PERSISTENT_SEQUENTIAL и EPHEMERAL_SEQUENTIAL, использую как "счетчик", в каком то случае я могу потерять счетчик(znode и с...

Типа есть 2 топика с фиксацией штрафа камерой и выпиской штрафа документально ?

А кафка же никакой фильтрации на стороне брокера не поддерживает ? (по ключу/хедеру)

Если с public схемой то примерно так 1) создаю таблицу временную таблицу like as со схемой tmp 2) загружаю в неё данные 3) в транзакции меняю схему у основной на swap, у време...

Может кто подсказать как должен работать Reclaim Policy: Delete ? Если пвц основанный на ск с ним, освобождается то данные в течении какого времени должны удаляться и можно ...

Спасибо большое. А известно где хранится оффсет для создания последующих SEQUENTIAL znodes ? (если например в следующей сессии запускаю вызов создания EPHEMERAL_SEQUENTIAL отк...

например row_number хочу и lag row_number() OVER w as A , lag(___) OVER w as B Он у себя под копотом за 1 проход постарается все посчитать? у меня просто получилось так что...

такое, тут явно была попытка разгрузить нагрузку с 1 ноды или сделать её более отказоустойчивой. Что произойдет когда читающие консюмеры упадут, ожидающие в случайном порядке ...

есть какой нить более экономный способ засунуть данные в inputStream ? out = new ByteArrayOutputStream() fori{ out.write(AnyString.getBytes()) } out.close() in = new ByteArray...

Можно как нибудь отслеживать все запросы в интернеты от питон скрипта ?(аля f12 в хроме) все вызовы к апи в библиотеке большой, каждый редачить не вариант

В пг можно как то проверить между 2 мя промежутками времени были какие либо изменения в таблице или нет?

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

При высокой частоте генерации случайных значений в несколько потоков реально же получать дубликаты ? 40к рпс на 4 ядра, по 2-4 дубля в ряд. Это реально получать из-за псевдосл...