коллеги, в большинстве статей описаны только кейсы с большой нагрузкой на запись и редкими чтениями может ли кликхаус держать большую нагрузку на небольшие и простые чтения и...
Привет! Мне нужно сделать таблицу, где бы хранились последние версии строк по 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].? ))) { ...
в скала плагине в akka http route от такого можно избавиться както? компилится но красное )
И что это меняет? Ты все равно должен будешь склеить кусочки чтобы произвести парсинг
@odomontois в cats нашел mapN, а есть что-то типа flatMapN?
@gamussa есть ли оф докер образ где только kafka client binaries? Не нашел в вашей репе, но часто надо Есть mesosphere/kafka-client, но там стара версия клиентов
всегда нужно возвращать конкретный тип, судя по примеру? как вернуть только statusCode без responseBody? как вернуть другой case class в случае ошибки?
Зачем писать? Rest proxy это сервис прокладка от confluent
Ты можешь сценарий проработать польностью в памяти, чтобы не расшивать легаси Или обязательно каждое обращение к внешнему сервису как отдельный эвент пробрасывать?
подскажите, пожалуйста, по pureconfig? - хочу чтобы работал generic method для маппинга в кейс класс https://scastie.scala-lang.org/fjAwbsvSSvaNbqDCglmddw