В случае с кафкой завести промежуточную очередь или канал и складывать в нее. Только следить за тем, что очередь не переполнилась. И комиттить только в том случае, если удалось в нее положить
А если на каждое соединение открывать свой клиент к пульсару? На установку соединения открываешь клиент, запускаешь цикл перекладывания в веб-сокет, на потерю соединения закрываешь клиент
Таков возник вопрос: получается в jetty адаптере ring есть перехватчик всех исключений, который превращает их в HTTP ошибки с номером 500, и без этого приложение просто падоло бы от любого исключения?
Ага, то есть приложение продолжало бы работать и отвечать на новые запросы, но в условном репле бы появилось сообщение об исключении? Ну, что бы точно понять спрашиваю