Билл БеджекKafka Streams в действии. Приложения и микросервисы для работы в реальном времени
Узнайте как реализовать потоковую обработку на платформе Kafka! В этой книге рассмотрены реальные примеры сбора, преобразования и агрегации данных. Показана работа со множественными процессорами, обработка событий в режиме реального времени. Вы узнаете даже о потоковом SQL с KSQL! Эксплуатация и тестирование, мониторинг и отладка современных распределенных систем — вы получите всю необходимую информацию о самых сложных аспектах потоковой обработки. Kafka Streams API — ключ к эффективному применению Kafka на практике.
Темы, рассматриваемые в книге:
• Использование KStreams API • Фильтрация, преобразование и дробление данных • Работа с Processor API • Интеграция с внешними системами
Стратегии повторов отправки — свойство retries задает число попыток повторной отправки на случай сбоя отправки пакета. Если порядок записей важен, имеет смысл установить свойству max.in.flight.requests.per.connection значение 1, чтобы второй пакет не оказался успешно отправленным до повторной отправки сбойного.