IG
у продьюсера кафки есть метод .applyAssync или что-то такое
Size: a a a
2020 June 11
IG
который принимает объект коллбек
IG
то есть .send(records, callback)
A
Ну значит ринг-хэндлер просто кинет асинхронно в кафку/еще куда, и выдаст респонс синхронно?
A
Мне на самом деле даже респонс не особо важен
IG
да, можно использовать простой синхронный ринг, просто слать в кафку асинхронно
IG
в callback предать reify-объект, который on-error пишет в лог или как-то сигналит об ошибке
A
Спасибо большое!
AV
✋ при старте powershell clj - 250Мб съедается. не знаете как уменьшить до 30 мб размер кучи при старте?
ST
Alex Varenik
✋ при старте powershell clj - 250Мб съедается. не знаете как уменьшить до 30 мб размер кучи при старте?
задай
-XmsAV
о
AV
похоже работает - не запустилась балалайка на 30
AV
а нет, -Xms файл ищет
ВБ
Подскажите, что не так написал?
ругается
No matching ctor found for class Yylex
(import Yylex)
(def obj (new Yylex "test "))
ругается
No matching ctor found for class Yylex
Н
и сейчас же не обязательно свою кафку поднимать, можно облачную купить
Вы про Event Sourcing или я что-то упустил?
IG
ну, я имел в виду что если много событий, которые нужно разобрать в фоне, можно скормить их кафке. А кафку поднять облачную у Confluent
IG
но автору вопроса виднее, какое окружение, требования, бюджет
MP
Alish
Господа, поделитесь пожалуйста мыслями по правильной реализации/best practices тривиальной штуки на Clojure:
Есть сайтик, который пушит кучу событий и телеметрии для аналитики, есть веб-сервер на кложе поверх ring, который должен эти события быстро поглощать и писать куда-то (в базу/тупо в файлы/неважно).
Я так понял надо на ring асинхронные хэндлеры реализовывать? Что еще? Core.async thread-ы юзать?
Есть сайтик, который пушит кучу событий и телеметрии для аналитики, есть веб-сервер на кложе поверх ring, который должен эти события быстро поглощать и писать куда-то (в базу/тупо в файлы/неважно).
Я так понял надо на ring асинхронные хэндлеры реализовывать? Что еще? Core.async thread-ы юзать?
какой плюс ожидается от асинхронных хендлеров?
ST
Alex Varenik
а нет, -Xms файл ищет
это опция к JVM, нижний размер кучи
ST
Валентин Бомбин
Подскажите, что не так написал?
ругается
No matching ctor found for class Yylex
(import Yylex)
(def obj (new Yylex "test "))
ругается
No matching ctor found for class Yylex
как описан
Yylex?