На странице собраны вопросы по Kafka — от проверки базовых принципов до практического применения и архитектурных решений. В подборке чаще встречаются темы: kafka, backend, api.
После отправки записи показывайте состояние ожидания и идентификатор операции. Календарь обновляйте из серверной модели чтения, а push или WebSocket используйте как сигнал получить актуальные данные.
Обоснуйте выбор требованиями: хранение истории событий, повторное чтение, независимые потребители, нагрузка и существующая инфраструктура. Не сводите решение к тезису «Kafka всегда быстрее».
Укажите, какой брокер реально использовали, какие сообщения проходили и что делали лично. Отправка события, администрирование брокера и потоковая агрегация — разные виды опыта.
Отправьте событие с уникальным идентификатором, дождитесь обработки в пределах таймаута и проверьте наблюдаемый результат. Старое сообщение нельзя принимать за результат текущего теста.
Объясните отсутствие очереди требованиями проекта. При небольшой нагрузке и необходимости немедленного результата синхронный обмен может быть проще и достаточен.
Укажите фактическое число прямых интеграций и разделите их на синхронные REST-вызовы и обмен событиями. Важнее числа — назначение связей и поведение при отказах.
Назовите реально применявшиеся Kafka-утилиты и задачи: просмотр топиков, отправку и чтение сообщений, проверку consumer group и offsets. Важно объяснить параметры, а не только вспомнить имена команд.
Да, поверх Kafka можно построить request-response с correlation ID и каналом ответов. Это прикладной протокол: подтверждение записи сообщения брокером не равно подтверждению бизнес-обработки.
Расскажите о реальном consumer: как задавали подключение, топик, группу, десериализацию и стартовую позицию. Проверка должна находить именно своё событие и иметь ограниченное ожидание.
Основные гарантии — at most once, at least once и exactly once в определённых границах. Они различаются возможностью потерь и повторной обработки; Kafka не делает произвольный внешний эффект автоматически однократным.
Kafka сама не возвращает бизнес-результат исходному HTTP-клиенту. Обычно API выдаёт идентификатор операции, а клиент узнаёт итог через polling, WebSocket, SSE или согласованный callback.
