Привет всем. Добавляют в спарке колонку в датафрейм через .withColumn("date", current_timestamp()). Почему при печатании схемы показывает date как nullable?Спарк 3
Привет. Кто-то пробовал подымать схему регистри в тимисти через docker compose build runner и читать или постить в нее схемы? Порты заэкспоузил, но курлом отдельным степом не ...
Всем привет. Нужно воспроизвести ситуацию когда текущий оффсет меньше earliest (есть проблема со спарк стримингом и кафкой по OffsetOutOfRangeException). Соответственно написа...
#kstreams Всем привет. Можно ли сказать что key.window().endTime() это есть таймстемп закрытия окна(в моем случаем Session Window). Или еще больше key.window().endTime() минус...
Скажите есть ли какой-нибудь известный баг у topologytestdriver, связанный с обрезанием пресижена до 1 после запятой для bigdecimal(например значение до pipeinput 0.00, а посл...
Слушайте, а есть ли какое то компромисное значение min.insync.replicas при 5 репликах? Скажем так у лэйтенси больший приоритет чем у консистенси
Schema evolution используется?