Как в Kafka гарантировать последовательность сообщений?
** порядок сообщений сохраняется за счёт их привязки к одному разделу, где они упорядочены по offset и последовательно читаются консьюмером.
Читать ответПодготовка к интервью
115 вопросов по Kafka с технических собеседований
Проверьте, насколько резюме подходит выбранной позиции, и получите рекомендации по улучшению.
Что проверяют на интервью
На странице собраны вопросы по Kafka — от проверки базовых принципов до практического применения и архитектурных решений. В подборке чаще встречаются темы: concurrency, backend, database.
Каталог
** порядок сообщений сохраняется за счёт их привязки к одному разделу, где они упорядочены по offset и последовательно читаются консьюмером.
Читать ответНадёжность доставки в Kafka обеспечивается за счёт репликации данных между узлами кластера Для этого применяется механизм ISR (in-sync replicas): запись подтверждают только реплики, которые синхронизированы с лидером…
Читать ответKafka и RabbitMQ: модели доставки push и pull Kafka использует pull-модель Воркер самостоятельно запрашивает появившиеся сообщения Это позволяет управлять темпом чтения: consumer контролирует offset Такой подход…
Читать ответмикросервисы — автономные сервисы, взаимодействующие через API REST: синхронное взаимодействие по HTTP/JSON, простая интеграция gRPC: синхронный и асинхронный обмен, бинарный протокол, высокая производительность…
Читать ответКак из сервиса вернуть доменную ошибку и отдать корректный HTTP-код? Контекст: обработка ошибок в backend-сервисах и API Для представления доменных ошибок применяю исключения (exceptions) либо error objects В…
Читать ответОбмен данными выполняется по асинхронному протоколу Для передачи используются очереди (queue) либо топики (publish-subscribe) Микросервисы отправляют сообщения в брокер и подписываются на нужные события Поддерживаются…
Читать ответКак корректно настроить http.Server.Shutdown для воркеров и ресурсов Контекст: graceful shutdown HTTP-сервера в Go http.Server.Shutdown выполняет плавную остановку: прекращает приём новых соединений и ожидает…
Читать ответКак корректно отменять горутины, выполняющие долгие операции? для управления долгими горутинными операциями в Go используется контекст следует применять context.Context вместе с отменой (CancelFunc) context нужно…
Читать ответраспределённая публично-подписная система потоковой обработки событий (event streaming) масштабирование выполняется за счёт партиционирования топиков каждый топик разделён на партиции, что обеспечивает параллельную…
Читать ответApache Kafka представляет собой распределённую платформу для обмена сообщениями и асинхронного взаимодействия сервисов Производитель (producer) публикует сообщения в тематические очереди, которые называются топиками…
Читать ответКак сохранить в Kafka только последнее событие пользователя? использовать ключи сообщений (key) — в качестве ключа передавать идентификатор пользователя включить для топика compaction — Kafka сохранит только последнее…
Читать ответExactly-once обработка в Kafka: как реализовать и что учесть Тема: обработка сообщений, Kafka, идемпотентность В основе exactly-once находится транзакционная запись в Kafka через Transaction API Применяется…
Читать ответ