сделал то же самое локально, нормально работает даже с одной и той же консьюмер группой
без кода тут никак не помочь
и я сам не считал, но кажется, больше половины вакансий за последний год упоминали FP в стеке
Читать полностью…Народ я очень прошу прощения за тупейший вопрос - хочу попробовать скалу на бекенде - какой самый дефолтный фреймворк для этого есть, типа спринга/джанги/аспкора/рельс итд?
Читать полностью…дело не совсем в том, в каком куске кода определяется, а внутри вызова receive, т.е. в том же треде, пока метод работает, или нет
Читать полностью…За пределами актора вы можете отсылать актору сообщения, в обработке которых уж можете спавнить, что вам нужно
Читать полностью…https://fd4s.github.io/fs2-kafka/docs/quick-example
Вот отсюда код.
Только либу взял последнюю 3.0.0-M8
опять же нужно взять и посчитать, но в среднем кажется, что больше есть шансов попасть на проект с cats, чем c play
Читать полностью…Всем привет. Такой вопрос, я правильно понимаю что бОльшая часть проектов на скале именно под веб написана на play? И как я понимаю комьюнити старается топить за FP. Но как погляжу - play - не очень про FP. Просто хочется работать именно с FP стеком но как вижу - туда фиг вкатешся джуном. И тогда выход только один - идти вначале на oop скалу, получать опыт и надеется что по достижению какого-то уровня выйдет свичнутся на fp?
Читать полностью…есть даже страничка в интернетах с объяснением почему так лучше.
https://nometa.xyz
ну и "я как-то раз попробовал сделать плохо, и вышло вроде нормально" не доказывает "можно в принципе делать плохо, и выйдет нормально"
Читать полностью…Если это акка тупед, и ctx - это ActorContext, то он и не должен в принципе работать за пределами receive
Читать полностью…Всем привет, такой вопрос, есть некий стрим который стримит сообщения с рэббита, я для каждого сообщения хочу создать актора, но актор почему-то не создается, в чем причина не подскажете ?
def startConsume(messageToBehavior: CommittableReadResult => Behavior[PerRequestCommand]): Future[Done] =Читать полностью…
run(Sink.foreach(message => ctx.spawn(messageToBehavior(message), "PerRequest")))
У меня при переходе на новую идею на одном проекте (основном рабочем) пришлось папку .idea удалять. Без этого ничего не помогало. На остальных проектах всё было ок
Читать полностью…