Содержание курса
9
разделов
48
уроков
25
тестов
2
задачи
3 ч.
обн. 31 марта 2026
1. О курсе
1 урок
322
275
6м
2
Открытый
1.1
Вводный урок
↗
322
275
6м 17с
2
2. Архитектура Кафка под капотом
6 уроков
641
605
25м
4
Закрытый
2.1
Архитектура брокеров и партиций
↗
133
133
5м 54с
0
Закрытый
2.2
Роль контроллера кластера, ISR (In-Sync Replicas)
↗
115
115
4м 28с
1
Закрытый
2.3
Распределение партиций и репликация
↗
105
105
5м 35с
0
Закрытый
2.4
Оптимизация производительности
↗
97
97
4м 41с
0
Закрытый
2.5
Тюнинг параметров продюсера: acks, linger.ms и др.
↗
96
81
5м 4с
1
Закрытый
2.6
Влияние параметров консьюмера: fetch.min.bytes, max.poll.records
↗
95
74
3м 36с
2
3. Транзакции и Exactly-Once семантика
7 уроков
404
370
33м
7
Закрытый
3.1
Идемпотентные продюсеры
↗
72
72
5м 47с
0
Закрытый
3.2
Настройка enable.idempotence=true
↗
63
63
4м 30с
1
Закрытый
3.3
Транзакции в Kafka
↗
58
58
5м 43с
1
Закрытый
3.4
API для транзакций: initTransactions(), beginTransaction()
↗
53
43
6м 50с
1
Закрытый
3.5
Обработка ошибок при commit / abort
↗
53
40
6м 23с
2
Закрытый
3.6
Консьюмеры в транзакционных системах
↗
51
51
3м 29с
1
Закрытый
3.7
Изоляция isolation.level=read_committed
↗
54
43
3м 11с
1
4. Кафка Streams для сложной обработки данных
8 уроков
324
323
25м
8
Закрытый
4.1
Топологии и процессоры
↗
45
45
4м 46с
1
Закрытый
4.2
Построение Directed Acyclic Graph (DAG)
↗
41
41
4м 35с
1
Закрытый
4.3
Использование Processor, Transformer, StateStore
↗
39
39
3м 24с
1
Закрытый
4.4
Окна и агрегации
↗
39
39
3м 41с
1
Закрытый
4.5
Tumbling, Hopping, Session Windows
↗
39
39
3м 21с
1
Закрытый
4.6
Агрегация с KGroupedStream
↗
40
40
3м 43с
1
Закрытый
4.7
Тестирование
↗
40
40
3м 3с
1
Закрытый
4.8
TopologyTestDriver для юнит-тестов
↗
41
40
3м 35с
1
5. Управление схемами и Schema Registry
6 уроков
213
213
18м
3
Закрытый
5.1
Интеграция Avro / Protobuf
↗
39
39
4м 43с
1
Закрытый
5.2
Генерация классов из схем
↗
35
35
3м 46с
0
Закрытый
5.3
Сериализация/десериализация с KafkaAvroSerializer
↗
34
34
3м 48с
0
Закрытый
5.4
Совместимость схем
↗
34
34
2м 21с
0
Закрытый
5.5
Стратегии: BACKWARD, FORWARD, FULL
↗
34
34
2м 29с
1
Закрытый
5.6
Использование Confluent Schema Registry
↗
37
37
3м 27с
1
6. Безопасность и мониторинг
6 уроков
222
219
16м
5
Закрытый
6.1
Аутентификация и авторизация
↗
39
39
3м 40с
0
Закрытый
6.2
SASL/SCRAM, SSL-шифрование
↗
37
37
3м 11с
1
Закрытый
6.3
Настройка ACL через kafka-acls.sh
↗
36
36
2м 30с
1
Закрытый
6.4
Мониторинг
↗
37
37
2м 14с
1
Закрытый
6.5
JMX-метрики Kafka (Lag, Request Latency)
↗
35
35
3м 46с
1
Закрытый
6.6
Grafana + Prometheus для визуализации
↗
38
35
3м 40с
1
7. Паттерны и антипаттерны
6 уроков
207
207
21м
3
Закрытый
7.1
Dead Letter Queue (DLQ)
↗
36
36
4м 1с
0
Закрытый
7.2
Обработка некорректных сообщений
↗
35
35
5м 32с
1
Закрытый
7.3
Retry-механизмы
↗
34
34
4м 26с
0
Закрытый
7.4
Экспоненциальная backoff-стратегия
↗
34
34
4м 53с
2
Закрытый
7.5
Порядок обработки сообщений
↗
33
33
3м 36с
0
Закрытый
7.6
Гарантии порядка в рамках партиции
↗
35
35
2м 44с
0
8. Практика: разбор кейса
7 уроков
245
211
14м
6
Закрытый
8.1
Транзакционное приложение
↗
37
37
2м 59с
2
Закрытый
8.2
План реализации
↗
35
35
4м 42с
1
Закрытый
8.3
Транзакции между Kafka и БД (Debezium).
↗
34
34
1м 25с
0
Закрытый
8.4
Kafka Streams для Real-Time Analytics
↗
34
34
2м 13с
1
Закрытый
8.5
Агрегация данных с оконными функциями
↗
34
34
2м 1с
1
Закрытый
8.6
Настройка безопасного кластера
↗
35
35
1м 29с
1
Закрытый
8.7
Развертывание с SSL/SASL в Docker
↗
36
2
1м 3с
0
9. Итоги
1 урок
7
2
0м
1
Закрытый
9.1
Итоги обучения
↗
7
2
-
1