Kafka + Spring 😕 база
Как отправить сообщение в Kafka из Spring?
Через KafkaTemplate: kafkaTemplate.send("topic", key, value) — Spring Boot настроит его автоматически.
Kafka + Spring 😕 база
Как читать сообщения из топика в Spring?
Метод с аннотацией @KafkaListener(topics = "orders") — Spring сам вызывает его на каждое сообщение.
Kafka + Spring 🤓 уверенно
Что такое groupId у @KafkaListener?
Идентификатор consumer group: слушатели с одним groupId делят партиции между собой, с разными — каждый получает все сообщения.
Kafka + Spring 🤓 уверенно
Как сериализуются объекты при отправке в Kafka?
Настраиваются сериализаторы: обычно JsonSerializer — объект превращается в JSON-строку и обратно на стороне потребителя.
Kafka + Spring 🧐 глубоко
Что произойдёт, если обработчик @KafkaListener бросит исключение?
Kafka + Spring 🧐 глубоко
Что такое ручной commit offset и когда он нужен?
Kafka + Spring 😎 про
Как настроить retry и dead letter topic в Spring Kafka?
Kafka + Spring 😎 про
Как обеспечить exactly-once обработку в связке Kafka + БД?