А нет. Там также асинк вызовы в бд 🌚

здравствуйте)

Товарищи, нужны ин процесс стримы. Задача банальная - кафку почитать, в бд записать, апи дёрнуть, в кафку положить. Требования - бекпрешур обязательно, асинхронность (ну есесна), лёгкая параллелизация ЦПУ операторов.

Не хочу спарк/флинк заводить ради такого. Желательно нативный котлин апи (корутины, все дела).

Не фига не понятно. Чем не годятся flow? Чем не годятся Java.Stream? Зачем там спарк?

Про флоу не в курсе, в котлине недавно. Джава стримы не асинхронные, там заводить .map( future) надо руками, бекпрешур только потому что они пул, но тот же спаркофлинк это делают с буфером грамотно, не тормозят чтение сорца постоянно

Ну и да, надо чтобы можно было просто написать что-то вроде
fastKafkaSource()
 .map(slowApiCall, workers = 4)

Кажется, Flow - это то, что вам нужно

Да, спасибо, посмотрю!

Неплохо. Выглядит достаточно для задачи.
Я не смог нагуглить сходу готовую обвязку для кафки. Она конечно несложно пилится, но если есть готовое, я бы взял.

Случайно не в курсе?)

Неа

Вот этого пока из коробки во Flow нет, но есть несколько доморощенных реализаций: https://github.com/Kotlin/kotlinx.coroutines/issues/1147

Минуту назад эту же ишую начал читать :D

Я минут 10 назад начал писать ответ, но отвлекся

Привет всем. По работе на некоторое время у меня будет макбук. Работать буду обычным программистом на котлине, без каких-то нестандартных особенностей. Вопрос: чего мне, человеку, который никогда не пользовался macos (но чуть-чуть всё-таки видел ее, например, на ютубе) ждать от этого перехода? Интересует не только конкретное программирование на котлине, но и обычные программерские задачи (вроде работы с терминалом, с гитом в частности)

котлин какой? JVM?

Да

Тогда вероятно ничего особенно ждать не стоит

Окей, класс. Просто интересно, если бы это был native, то там были бы какие-то принципиальные отличия от винды? Ну, кроме другого компилятора

Другой компилятор

Я просто не до конца понимаю все особенности, которые вытекают из этого