Kafka Streams и ksqlDB: данные в реальном времени [Митч Сеймур] (pdf) читать постранично, страница - 2

издательства..............................................................................................................................24

ЧАСТЬ I. KAFKA
Глава 1. Краткое введение в Kafka...............................................................................................26
Модель взаимодействия............................................................................................................27
Как хранятся потоки.....................................................................................................................31
Темы и разделы..............................................................................................................................34
События.............................................................................................................................................36
Кластер и брокеры.......................................................................................................................37
Группы потребителей..................................................................................................................39
Установка Kafka..............................................................................................................................41
Hello, Kafka........................................................................................................................................43
Заключение......................................................................................................................................45

ЧАСТЬ II. БИБЛИОТЕКА KAFKA STREAMS
Глава 2. Начало работы с Kafka Streams...................................................................................48
Экосистема Kafka...........................................................................................................................48
До появления Kafka Streams..............................................................................................49
Рождение Kafka Streams......................................................................................................51

Оглавление  7
Обзор функционала.....................................................................................................................52
Эксплуатационные характеристики.....................................................................................53
Масштабируемость................................................................................................................54
Надежность...............................................................................................................................55
Удобство сопровождения...................................................................................................55
Сравнение с другими системами...........................................................................................56
Модель развертывания.......................................................................................................56
Модель обработки.................................................................................................................56
Каппа-архитектура.................................................................................................................57
Сценарии использования..........................................................................................................59
Топология обработчиков...........................................................................................................61
Субтопологии...........................................................................................................................63
Обработка вглубь...................................................................................................................64
Преимущества программирования потоков данных............................................66
Задачи и потоки выполнения...........................................................................................67
Высокоуровневый DSL и низкоуровневый API
узлов-обработчиков....................................................................................................................70
Начало практической работы: Hello, Streams...................................................................71
Настройка проекта................................................................................................................72
Создание проекта...................................................................................................................72
Добавление зависимости Kafka Streams......................................................................74
Вариант на базе DSL..............................................................................................................75
API узлов-обработчиков......................................................................................................77
Потоки данных и таблицы.........................................................................................................80
Потоково-табличный дуализм..........................................................................................83
KStream, KTable, GlobalKTable............................................................................................84
Заключение......................................................................................................................................85
Глава 3. Обработка без сохранения состояния.....................................................................86
Обработка с сохранением и без сохранения состояния............................................87
Обработка потока твитов..........................................................................................................88
Настройка проекта.......................................................................................................................90
Добавление узла-источника KStream...................................................................................90
Сериализация/десериализация.............................................................................................94
Пользовательская версия класса Serdes.....................................................................95
Определение классов данных..........................................................................................96

8  Оглавление
Пользовательский десериализатор...............................................................................97
Пользовательский сериализатор....................................................................................98
Класс Serdes для твитов.......................................................................................................99
Фильтрация данных.................................................................................................................. 100
Ветвление данных...................................................................................................................... 102
Перевод твитов........................................................................................................................... 104
Слияние потоков........................................................................................................................ 106
Обогащение твитов................................................................................................................... 107
Класс данных