M

@gamussa если дернуть админ клиент и на фьюче навернуть whenComplete то админ клиент зависнет при клоузе навеки даже не смотря на возвращенный колбак def timed[F[_]: Concurr...

что то отсюда ? labels: beta.kubernetes.io/arch: amd64 beta.kubernetes.io/instance-type: c5.xlarge beta.kubernetes.io/os: linux failure-domain.beta.kubernet...

Are you shure ? Here is explanation from documentation A Resilient Distributed Dataset (RDD), the basic abstraction in Spark. Represents an immutable, partitioned collection ...

Kirill https://fs2.io/concurrency-primitives.html паб саб который пример, тока у тебя будет не дрейн а резалт кью куда ты будешь собирать все и потом возвращать? только приде...

есть пример кода на скале напилить квик сорт в тейл рекурсив форме не юзая всяких стейт монад и тому подобные коричневые кучи ?

пацаны а для Iterable[Decoder.Result[Myclass]] какой апликатив надо засумонить чтобы свернуть все секуенсом в Decoder[Iterable[Myclass]] в цирке или свой надо писать?

Чувак ты вопрос задать нормально не можешь, открыть доку не можешь, ждёшь готового решения ?) Иди почитай

trait Foo { type X = VeryLongTypeName1 type Y = VeryLongTypeName2 } case class Foo0[A, B]() def foo(foo: Foo): Foo0[foo.X, foo.Y] = ?...

никто не сталкивался с проблемой что при закрытии кафка админ клиента все приложение висит бесконечно?

судя по гласдору нету https://www.glassdoor.com/Job/jobs.htm?suggestCount=0&suggestChosen=true&clickSource=searchBtn&typedKeyword=Scala&sc.keyword=Scala&locT=C&locId=2904022&j...

так не работает ? def fromString(str: String): Either[String, Id] = Try(UUID.fromString(str).coerce[Id]).toEither.left.map(_.getMessage)

пацаны а как вы живете с тем что кафка клиент нульпоинтеры кидает постоянно?

какие кирпичики мне нужно втащить чтобы делая мердж на фс2 стримах не иметь канкарентеффекта в скоупе?

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

@odomontois Олег когда спидран ?)

Муник или хамбург?

В рчайне у головача насмотрелся?)

Каждый партишен в отдельном потоке, чекпоинтинг со сторингом офсета и ретраями не достаточно?

а откуда в фс2 бекпрешер ?

Ты про какое апи друг, фс2 кафка? Кскуель, кстрим, сырой кафка консумер джавовый, альпака