ΛВ
О, вспомнил когда ещё хттп4с ломается так — прям вот недавно было, что мидлвари могут тела стрим читать, и потом его заново уже не вычитать
Size: a a a
2021 December 06
ΛВ
Даже https://github.com/http4s/http4s/pull/5321 чинили там
AS
Было такое, да.
AS
> потом его заново уже не вычитать
Оооо...
Мой любимый тип багов с http4s 😍
Оооо...
Мой любимый тип багов с http4s 😍
NM
получается кишки хттп4с нарушают RT?
AS
Могут нарушать. Если тело ответа считают за тебя(твой код)
ΛВ
не, RT не ломается. Просто тело — стрим
ΛВ
и этот стрим может быть привязан к реальному сокету
ΛВ
и body.compile.toList : F[Unit]
ΛВ
не гарантирует одинаковость
NM
спасибо Антон, звучит логично - до меня теперь тоже дошло
RO
Привет. Может ли кто подсказать по Спарку. Хочу дата фрейм, созданный из Seq элементов, застримить на кафка топик. Ловлю ошибку, что запись возможно только из стримового источника. Т.е. df = Seq(human1, humanN).toDF.writeStream не работает. Нагуглил, что нужен стрим контекст но не могу найти внятного примера
Oℕ
Сложноватый вопрос для этой группы, кажется, это скорее
в https://t.me/hadoopusers
в https://t.me/hadoopusers
RO
Они тут один стрим вешают на другой. А я хочу из чистых данных застримить n элементов.
RO
Считай, хочу создать утилиту для ручного подбрасывания парочки сообщений в топик. Но написанную через спарк стриминг.
Sa
А источник это стрим или батч?
DL
Доброго времени суток