Перейти к содержанию

Практикум: проверка aiokafka перед продакшеном

Один контейнер Kafka и скрипты для проверки каждого вопроса: с какими настройками продюсер отказывается создаваться, как работают сериализаторы значения и ключа, что перечитывает новый консьюмер, какие смещения фиксирует auto-commit, что происходит при обработке пачки дольше max_poll_interval_ms, как создаются топики и сколько стоит проверка здоровья при приостановленном брокере.

  • checklist_lab.py — проверка по разделам статьи.
  • topic_probe.py — проверка того, может ли ensure_topics_async вообще создать топик.
uv venv --python 3.13 .venv
uv pip install --python .venv/bin/python "aiokafka-foundation-kit[models]==0.1.3" "testcontainers[kafka]"
.venv/bin/python checklist_lab.py
.venv/bin/python topic_probe.py

Исходный код практикума на GitHub.