я к тому что если есть такое требование как через 3 секунды простоя детектируется авария, то добавление туда ЕО видится как добавление лага просто так, а выигрыш в этом какойто есть?
по сказанному выше кажется, что вам нужно просто подтверждение отправки в кафку со стороны датчиков и хотя бы раз прочитать в приемлемое время и это обычны at-least-once
всем привет, как лучше обрабатывать ошибку при отправке через кафка-темплейт(spring-kafka), когда такого топика в кафке нету, сейчас работает так, что сенд в бесконечный ретрай уходит и колбек который выбрасывает эксеп не срабатывает в итоге?
единственно не знаю как кафка будет отрабатывать пабдение брокера, если реплика фактор единица. Выделятся ли новые партиции на оставшихся брокерах или там оно помрет. Если это будет быстро, то можно еще отказаться от реплик и еще и тут прирост по скорости получить
просто можно поставить буферную простую кафку для оперативных данных на хранение десятка минут с низкими гарантиями и рядом поставить уже полноценный кластер кафки с репликациями для более длительного хранения и возможности переналивать базы и перекидывать из первой во вторую
всем привет! подскажите бесплатный клиент для кафки, чтобы можно было читать из очереди и пушить в очередь пользуюсь conduktor , но почти 3к рублей каждый месяц платить - затратно чем вы пользуетесь? поделитесь плиз