λ
Да я сделаю конечно, я просто не за компом. Думал, может ты уже знаешь в чем проблема
Size: a a a
2021 January 16
ЮБ
Да я сделаю конечно, я просто не за компом. Думал, может ты уже знаешь в чем проблема
Сорян, но нет. Если поможет - зарепорть ишью
λ
Точно не уверен, что в этом причина, но там какая-то бинарная несовместимость в новой версии. Попробуй заэкслкудить
не помогло
ЮБ
не помогло
Беда
ЮБ
А пишется в кафку тоже через fs2-kafka?
ЮБ
Может что-то в продюсере сломали случайно
λ
Ну так у меня ембеддед самый свежий и все работало.
А вот фс2-кафка релизнута на предпоследнем ебмеддеде
А вот фс2-кафка релизнута на предпоследнем ебмеддеде
Натрави на докер кафку, 2021 год на дворе, а ты все эмбед используешь
λ
А пишется в кафку тоже через fs2-kafka?
Потыкал. С produce.flatten работает. С просто produce без ожидания даже с очень большим таймаутом сообщения обратно не вычитываются.
GP
Потыкал. С produce.flatten работает. С просто produce без ожидания даже с очень большим таймаутом сообщения обратно не вычитываются.
ну вот проверь на реальной кафке вообще чето отсылается или нет
может не в ембедед кафке дело
может не в ембедед кафке дело
GP
из консоли послушай топик в который срется
2021 January 17
ЮБ
Потыкал. С produce.flatten работает. С просто produce без ожидания даже с очень большим таймаутом сообщения обратно не вычитываются.
Это немного странно. Но вообще, нужно делать либо flatten, либо как-то ещё ждать оба F. Так и раньше было.
λ
Это немного странно. Но вообще, нужно делать либо flatten, либо как-то ещё ждать оба F. Так и раньше было.
Да нет вообще-то. produce через старт файбера написан. Если делать flatten, то форсируешь join. Если не делаешь, то это fire-forget. И раньше все работало без флаттена
λ
Видимо тут сломали https://github.com/fd4s/fs2-kafka/pull/418/files
λ
Это немного странно. Но вообще, нужно делать либо flatten, либо как-то ещё ждать оба F. Так и раньше было.
Вроде понял, что произошло. Раньше продьюс запускался сразу, хоть и асинхронно. А потом они форкнули вызов продьюса в файбер и теперь момент, когда этот код отработает, скедулится ио рантаймом. И перфомансу как-то поплохело в тестах )
ЮБ
Видимо тут сломали https://github.com/fd4s/fs2-kafka/pull/418/files
Ну там по факту семантика не должна была изменится
ЮБ
Только способ реализации изменился
ЮБ
На самом деле вы просто опирались на неявное поведение
λ
Ну там по факту семантика не должна была изменится
Тем не менее, теперь fire-and-forget занимает неопределенное время, даже 60 секунд таймаута не всегда хватает. Не очень понятно, как теперь это в проде себя поведет
λ
На самом деле вы просто опирались на неявное поведение
Возможно. Но я не понял твои слова, что надо всегда flatten делать (т.е. форсировать дожидание результата продюса)
λ
По-моему апишка как раз дает очевидный выбор