Перейти к содержимому

Kafka

Вопросов: 67 из 34 собеседований. Источник указан в заголовке группы.

  • Чем Kafka отличается от RabbitMQ?
  • Какие плюсы и минусы у Kafka?
  • кафка - 1 партишн и 3 консьюмера, 3 партишена - 1 консьюмер
  • Что позволяет не читать каждый раз сообщения из кафки заново?
  • Кто хранит оффсет в кафке?
  • Можно ли читать один топик несколькими консьюмерами параллельно?
  • Что такое партиция в кафке?
  • Standard Kafka questions;
  • Гарантирована ли доставка сообщений в кафка?
  • За счет чего обеспечивается отказоустойчивость Kafka?
  • Какие гарантии доставки предоставляет Kafka?
  • Стандартные вопросы про Kafka?
  • Расскажи про гарантии доставки Kafka;
  • Работал с кафкой?
  • Что такое топик, партиция, producer и consumer?
  • Что такое consumer lag и из-за чего он бывает?
  • дефолтные вопросы по Go, БД и Kafka.
  • Какие есть основные абстракции в Kafka?
  • Что будет, если партиций больше, чем консюмеров в одной группе потребителей?
  • На уровне чего поддерживается в Kafka порядок сообщений?
  • Какие у Kafka гарантии доставки?
  • Как в Kafka реализуются семантики доставки «at most once» и «at least once» на уровне механизма работы системы?
  • Что такое Exactly-once в Kafka?
  • Что произойдет с уже существующими данными в топике Kafka, если увеличить количество партиций - например, с 10 до 20 - пока часть сообщений еще не была потреблена? Что произойдет, и можно ли уменьшить количество партиций обратно с 20 до 10?
  • Что такое ConsumerLag?
  • Есть ли опыт работы с Kafka?
  • Как можно разрешить Consumer Lag?
  • Гарантирует ли Kafka уникальность и последовательность сообщений?
  • По Kafka: как работает консьюмер группа? Что такое партиция? Если партиций больше чем потребителей, как поделятся потребители и партиции? А наоборот потрателей больше партиций? За счет чего обеспечивается каждый потребитель будет читать только свои данные, а не другие, где хранятся инфо о том что-то прочитано или нет? При отказе приложения, когда перестартает за счет чего он продолжит читать с того сообщения на котором он упал? Где хранятся смещения, что в них?
  • Условная задача: какие-то сообщения поступают через Kafka и мы должны эти сообщения перекидывать в другую систему, но есть ограничьение, что тa внешняя система (куда мы перекидываем) не может обрабатывать больше чем 10 одновременных запросов, как реализовать это ограничьение используя примитивы языка Go?
  • Кафка: что такое и зачем нужны партиции, топики? как обеспечить гарантию отправки сообщений?
  • Как вы использовали Kafka?
  • Про Kafka базовые вопросы.
  • В чем ключевые различия между Kafka и RabbitMQ?
  • В Kafka куда отправляем сообщения и откуда забираем?
  • Можем записать сообщение в отдельную партицию?
  • Как замерить пропускную способность на кафке?
  • Что такое оффсет в кафке?
  • В потоке синхронно приходит количество списаний по пользователю. Как организовать асинхронную работу в данном случае? На что надо обращать внимание в случае использования кафки настройки подписчика и настройки продюсера?
  • Если consumer упал до того, как сообщение было обработано, как гарантировать повторную обработку этого сообщения? Как Kafka в этом случае управляет offset?
  • Что такое consumer lag в Kafka? Чем он опасен и как его мониторить?

SberMobile / СберМобайл (Хранитель/Антиспам) — 1 кв 2025

Заголовок раздела «SberMobile / СберМобайл (Хранитель/Антиспам) — 1 кв 2025»
  • Kafka. Консьюмерная группа одна. Консьюмеров больше партиций. Чем это грозит?
  • Что такое топик у Kafka?
  • Чем натс отличается от кафки? Расскажи как работал с кафкой
  • Представь что есть в кафке топик с тремя партициями, туда пишутся данные. Ты пишешь приложение со стороны консюмера. Сколько консюмеров нужно задействовать, чтобы наиболее оптимально вычитывать этот топик?
  • Представь что ты написал консюмер, он читает из кафки какие-то данные, один топик, одна партиция, один консюмер. Нам сказали что копится лаг. Ты зашел в логи консюмера и увидел что там ошибка при анмаршалинге данных (например нам прислали битый json). Нам нужно оперативно пофиксить эту проблему. Как ее решить?
  • Допустим у нас сервис читает из топика сообщения, и на каждое сообщение пишет в базу что-то. У нас стало слишком много сообщений, и база не справляется. Как решить проблему на уровне сервиса?
  • Чем отличается Kafka от RabbitMQ?
  • Какие библиотеки использоавл для работы с Kafka?
  • Чем отличается rabbitmq от kafka?
  • Для чего нужна консьюмер группа в кафке?
  • Если есть три партиции на один топик и мы отправляем туда сообщение, то в какое кол-во партиций это сообщение попадет?
  • Чем отличается NATS от кафки?

Wildberries / WB - 10 (Складская логистика) — 1 кв 2025

Заголовок раздела «Wildberries / WB - 10 (Складская логистика) — 1 кв 2025»
  • Использовали ли Kafka? Как?
  • Чем kafka отличается от mq rabbit?
  • Расскажи про kafka
  • Есть ли у вас опыт работы с Kafka?
  • Как настроить Kafka, чтобы все 10 реплик сервиса получали и обрабатывали одни и те же сообщения из топика?
  • Как вы обрабатываете ошибки при потреблении сообщений из Kafka?
  • Можно ли настроить Kafka как умного брокера и глупого клиента?

Wildberries / WB - 5 (Команда спецпроектов) — 1 кв 2025

Заголовок раздела «Wildberries / WB - 5 (Команда спецпроектов) — 1 кв 2025»
  • Партиции логические или физические?
  • Какие есть основные компоненты в Kafka?
  • Чем отличается топик от партиции?
  • Какие есть гарантии доставки?
  • Что такое консумер группа?
  • Ты говоришь, что работал с кафкой и натс. Можешь рассказать какие-то особенности? Почувствовал ли разницу какую-то или одинаково?
  • Почему использовал кафку, а не более легковесное решение?