Nikita Matveenko

почему скала компайлер видит s"${true}" в equals"${true}" если equals это метод на java.lang.Object?

Спасибо что спросил :) В общих словах это что-то типа event sourcing (read model) - KStream (S1) -> groupByKey -> aggregate -> join back with S1, на выходе пишу в отдельный т...

Http() .newServerAt("0.0.0.0", port = port) .bindSync(handler(registry)) terminate на таком работает правильно и сервак выключен когда футурка комплитится а если делать ...

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

@simpadjo почему надо выкидывать джвм? есть какие-то материалы почитать - просто любопытно

IO run loop - IO[Any] тип в котах 2.4, без Any никак? Может есть какие-то гисты почитать про историю развития ИО ран лупа? https://github.com/typelevel/cats-effect/blob/163e3...

О, крутая тема и правдивый заголовок на превью для видео, а ты там рассказываешь почему тестов нет в самих кафка стримах на ребаланс и корректное восстановление стейта? Или уж...

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

@gamussa доброго времени суток, у меня такое ощущение что я наткнулся на критичный баг в кафка стримах (как https://issues.apache.org/jira/browse/KAFKA-7192) и возможно он поя...

https://twitter.com/mchlpalka/status/1483779863194574850?s=20 equals"${true}" превращается в StringContext("", "").equals(true)?

скаланы - есть глубокие знания по двжм? я вот не могу найти инфу про безопаность ловли StackOverflowError в тестах на JVM https://github.com/typelevel/cats-effect/pull/1923

@gamussa привет, можешь подсказать есть ли в кафка стримах гарантия что сообщения в output (SinkNode) флашнутся перед changelog? А то сейчас я наблюдаю ситуацию когда у меня н...

@lmnet89 тогда получается на основе cancellation лучше не строить логику - а явно в своих циклах проверять условия выхода?

Ребята, а пока это https://cwiki.apache.org/confluence/display/KAFKA/KIP-354%3A+Add+a+Maximum+Log+Compaction+Lag улучшение еще обсуждается , есть ли какие-то статьи подсказк...

скаланы, вопрос про circe AutoDerivation - есть возможноть получить уточнение от компилятора про ошибку "could not find implicit value for parameter encoder Encoder[OuterEntit...

спасибо, а если меня конкретный вопрос интересует про долгое время восстановления state store - у меня RocksDB файлы не сохраняются между запусками стримов, и поэтому кафка ст...

а можно как-то сделать чтоб этот модифай применять от имени инстанса кейс класса? типа val person = Person(name = "Some name", address: Address(street = "street")) person.mod...

знаешь еще какие-то годные реализации линз? я вот видел в scalapb такой вариант mosh.update( _.address.update( _.city := "Valejo", _.street := "Fourth" ...

Oleg а можно как-то получить немного другой синтаксис апдейта в монокле типа как я указывал выше? или это будет противоречить каким-то принципам? mosh.update( _.address....

а скаланы еще вопрос, вот есть у меня стрим, на входе A на выходе B, и я хочу этот стрим сконвертить в Task[A => List[B]] или Future, как такое сделать?)