Если разберешься, свисти =)

Ну видимо не надо поверх шины. Надо поверх такого тчо умеет ACK на отдельное сообщение (rabbit)

Кажется nats же умеет gprс и custom acks

Как вариант

Я об эту задачу тоже много страдал

И latency kafka меня просто убивала там.
Не скажу что решил прямо идеально, но вообще просто понял что не надо кафкой решать

какая самое хорошая кника по кафке?

kafka the definitive guide видимо

Русский перевод очень сложно читать. Дословный перевод привычных терминов просто ужс

русский не надо

Доброе утро. Возможно вопрос не в ту тему (не могу четко определится в чатики по java вопрос задать  или здесь).
Использую spring-kafka и хочу сделать handler для ситуации, когда брокер kafka недоступен. Сейчас KafkaListener стартует при запуске приложения и если брокер кафка недоступен, то приложение просто не стартует.

Пробовал в ConcurrentKafkaListenerContainerFactory устанавливать setErrorHandler и setMissingTopicsFatal, но все равно не ловится исключение. Может кто подсказать как это реализовать?

Если сервис не смог обработать сообщение то это проблема сервиса что дальше делать. Если нужна повторная обработка, то DLQ. Жаль что нет из коробки, приходится велосипед изобретать

DLQ есть в RabbitMQ, вот как раз изучаю

А есть более-менее стандартизированный велосипед для DLQ?

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

в пульсаре тоже есть из коробки

this

Что не обязательно a good thing

Привет!
Кто-то пилил rules engine на Kafka Streams?
Какой подход применяли?

Мы думаем как бы красивее реализовать систему алертинга, которая простыми конфигами натравливается на нужные метрики

Я бы на ksqldb поглядел