Если у вас стек целиком на TypeScript, Kafka или вы уже читаете через @platformatic/kafka или KafkaJS, и захотелось Kafka Streams - это для вас. Состояние по ключу (счетчики, агрегаты, окна) обычно живет в Redis или Postgres, и при падении консьюмера посреди батча получаете дубли или потерянные обновления. В Java для этого есть Kafka Streams. В Node.js аналога нет, а поднимать отдельный JVM-сервис ради этого дорого. kstreams-ts переносит модель Kafka Streams в Node.js, поверх @platformatic/kafka . Состояние живет рядом с обработкой и переживает падения и ребалансы, а в режиме exactly-once каждая запись учитывается ровно один раз. Читать далее
Continue to Habr →You are being forwarded in 6s — stay on this page