Kafka: настройка топика, продюсера и консюмера — тест

Нужно запустить брокер, изменить retention, подтвердить обработанные сообщения и выбрать настройки продюсера. Эта подборка проверяет конкретные команды и параметры Kafka; работающий кластер для ответа не нужен.

Как проходить

Пройдите вопросы в порядке от запуска KRaft к обработке событий. На вопросах про batch.size, linger.ms и acks отдельно подумайте о задержке и подтверждении записи. Это разные свойства: высокая пропускная способность сама по себе не означает более сильных гарантий доставки.

Задания

  1. Kafka KRaft: порядок подготовки и запуска.
  2. Kafka: изменить retention существующего топика.
  3. Kafka: ручной commit offsets после обработки.
  4. Kafka Streams: чем строят топологию.
  5. Kafka Streams: окна без перекрытия.
  6. Kafka Connect: классы собственного Sink Connector.
  7. Kafka batch.size и linger.ms: скорость и задержка.
  8. Kafka acks: подтверждения и надёжность записи.

После отдельных вопросов можно перейти к последовательной практике в курсе Data Engineering Fast‑Track: Kafka → Airflow → Spark. Посмотрите программу и доступные пробные уроки, чтобы выбрать следующий шаг.