Подготовка к интервью
Разбирайте реальные вопросы, сверяйтесь с подробными ответами и готовьтесь по технологиям и компаниям.
Проверьте, насколько резюме подходит выбранной позиции, и получите рекомендации по улучшению.
Каталог
Растущий consumer lag в Kafka означает, что потребитель не успевает обрабатывать сообщения с той скоростью, с которой они поступают, что может привести к задержкам и переполнению буферов.
Читать ответKafka изначально не предназначена для долговременного хранения данных, а скорее для передачи и обработки потоков сообщений с высокой пропускной способностью и низкой задержкой.
Читать ответKafka — это мощная распределённая платформа для обработки потоков данных, но она не универсальна для всех сценариев.
Читать ответKafka — это распределённая платформа обмена сообщениями, которая эффективно работает с несколькими инстансами приложения благодаря концепции consumer group и партиций.
Читать ответВ контексте Kafka термин TTA (Time To Acknowledge) обычно относится к времени, которое требуется системе или потребителю, чтобы подтвердить получение и обработку сообщения.
Читать ответДля тестирования Kafka-продюсера и консюмера на Java часто используют библиотеку spring-kafka-test или EmbeddedKafka из Spring Kafka, которая позволяет поднять встроенный Kafka-брокер в памяти.
Читать ответEvent-driven взаимодействие с использованием Apache Kafka предполагает обмен сообщениями между сервисами через публикацию и подписку на события.
Читать ответИдемпотентная отправка в Kafka достигается за счёт уникальных идентификаторов сообщений и контроля последовательности (sequence numbers) на стороне продюсера.
Читать ответВ Kafka транзакции обеспечивают атомарность записи сообщений в несколько партиций и топиков. Уровни изоляции транзакций в Kafka определяют, какие сообщения видны потребителю:
Читать ответПервым делом изучу текущую архитектуру сервиса и пойму, где именно нужна интеграция с Kafka: для продюсинга, консьюминга или и того, и другого.
Читать ответKafka Streams — это библиотека для обработки потоковых данных, построенная поверх Apache Kafka. Она позволяет создавать приложения, которые читают, обрабатывают и записывают данные в Kafka в режиме реального времени.
Читать ответДля распространения бизнесовых заголовков (например, x-session-id, x-client-id) по системе микросервисов через REST и Kafka можно использовать следующий подход:
Читать ответ