Oleg

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

Привет! Мне нужно сделать таблицу, где бы хранились последние версии строк по ID требуется, чтобы дедубликация прошла на момент вставки чтобы от пользователя не требовалось...

java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(Cons...

подскажите, безопасно ли будет конкурентно писать разными потоками в непересекающиеся диапазоны в int array? - например, 1 поток работает с [0,50], второй только с [51,100] -...

@gamussa а cp-kafka-connect образы можно запускать под java11-14 ?

коллеги, подскажите по облачному битрикс CRM мне нужно сделать обработчик события я правильно понимаю, что в облаке это можно сделать только исходящим вебхуком?

спасибо! еще вопрос - есть 3 треда и массив тред1 изменил диапазон1 и дальше что-то делает тред2 изменил непересекаюшийся диапазон2 и дальше что то делает как треду3 увиде...

akka streams - если сорс не отдает данных, можно ли его сделать с exp backoff, чтоб не обращаться к апи слишком часто? и с другой стороны, если в сорсе есть данные, то извлека...

коллеги, есть ли способ выполнить скрипт на ec2 при событии terminate ec2?

Есть ли способ в postgres не инкрементить sequence при failed insert? У меня логика завязана на insert on conflict do nothing, и счетчики опасно большие накручиваются, даже д...

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

private val read = (post & pathPrefix("read") & parameters(( "raw".as[Boolean].?, "offset".as[Int].?, "pageSize".as[Int].? ))) { ...

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

@odomontois в cats нашел mapN, а есть что-то типа flatMapN?

@gamussa есть ли оф докер образ где только kafka client binaries? Не нашел в вашей репе, но часто надо Есть mesosphere/kafka-client, но там стара версия клиентов

всегда нужно возвращать конкретный тип, судя по примеру? как вернуть только statusCode без responseBody? как вернуть другой case class в случае ошибки?

подскажите, пожалуйста, по pureconfig? - хочу чтобы работал generic method для маппинга в кейс класс https://scastie.scala-lang.org/fjAwbsvSSvaNbqDCglmddw

Зачем писать? Rest proxy это сервис прокладка от confluent

Ты можешь сценарий проработать польностью в памяти, чтобы не расшивать легаси Или обязательно каждое обращение к внешнему сервису как отдельный эвент пробрасывать?