Сообщения в Spring

Основа с Middle

Spring Kafka, Spring AMQP и Spring Cloud Stream.

Что важно знать

KafkaTemplate, @KafkaListener, DefaultErrorHandler, DLT.
Режимы подтверждения и транзакции Kafka в Spring.
RabbitTemplate, @RabbitListener, ack-режимы, повторы.
Cloud Stream — функции и биндинги, переносимость между брокерами.

Критерии освоения

Middle ≈ 8 ч

Пишет продюсер и потребитель Kafka на Spring Kafka с обработкой ошибок и DLT
Настраивает подтверждения и повторы в Spring AMQP
Объясняет, когда уместна абстракция Spring Cloud Stream

Практика. Реализовать обработку событий заказа на Spring Kafka с повторами, DLT и интеграционным тестом в Testcontainers.

Вопросы с собеседований

Что делает аннотация @KafkaListener? Junior
@KafkaListener(topics = "orders", groupId = "billing") объявляет обработчик: цикл poll(), десериализацию, вызов метода и коммит offset берёт на себя контейнер Spring Kafka.
Что важно задавать при отправке через KafkaTemplate? Middle
Задавать ключ (порядок и партиция по сущности), сериализатор и формат, обрабатывать результат отправки — она асинхронная; для надёжности — acks=all и идемпотентный продюсер (по…
Как @KafkaListener связан с listener container и offset commit? Senior
@KafkaListener — метод, который вызывает listener container: контейнер крутит цикл poll() в своих потоках, вызывает метод для записей и коммитит offset по AckMode. По умолчанию…
Что означает подтверждение (ack) сообщения в RabbitMQ? Junior
Ack — сигнал брокеру, что сообщение обработано: до него сообщение считается невыполненным и при обрыве соединения вернётся в очередь другому потребителю.
Для чего нужен RabbitTemplate в Spring AMQP? Middle
RabbitTemplate — основной способ отправки в Spring AMQP: convertAndSend(exchange, routingKey, payload) с конвертером сообщений (JSON через Jackson2JsonMessageConverter), плюс…
Как в Spring Kafka обычно строят retry и dead letter topic? Senior
Два способа: блокирующий — DefaultErrorHandler с BackOff и DeadLetterPublishingRecoverer (повторы на месте, партиция ждёт); неблокирующий — @RetryableTopic: запись уходит в…

Разборы темы

Spring Cloud Stream
Binder abstraction, functional model, bindings, consumer groups, partitioning и trade-offs поверх Kafka/RabbitMQ.
Spring AMQP и RabbitMQ
RabbitTemplate, @RabbitListener, exchanges, bindings, manual ack, retries, DLQ и prefetch.
Spring Kafka
KafkaTemplate, @KafkaListener, listener containers, offset ack, error handling, retries и DLT.

← Вся карта «Spring»

Закрытая бета

Знать тему — половина дела

На живом собеседовании sotto слышит вопрос интервьюера и показывает короткий ответ и план. Оставьте контакт — пришлём доступ и промокод.

Промокод на 2 часа — сверх пробных 30 минут
Программа для Windows — скачать сразу, войти — через Яндекс ID или VK ID
Первыми узнаете о версии для Mac — пока sotto только для Windows
Прямая связь с разработчиком: что улучшить — сделаем