Работа с Apache Kafka в Java: Полное руководство для начинающих

• Создаем новый проект и называем его "пойнт микросервис".  

• Добавляем зависимости: lombok, spring-kafka, lambdable.  

• Настраиваем сервер и порты для работы с Kafka.  

• Указываем серверы для Kafka Producer.  

• Определяем типы сообщений: ключ и значение.  

• Настраиваем локальные адреса серверов.  

• Создаем конфиг для Spring Kafka Producer.  

• Добавляем переменные из файла application.properties.  

• Создаем метод для возврата конфигурации Kafka Producer.  

• Создаем бин для управления Spring Kafka Producer.  

• Указываем формат ключа и значения.  

• Создаем бин для отправки сообщений.  

• Создаем топик для отправки сообщений.  

• Указываем количество партиций и реплик.  

• Настраиваем минимальное количество реплик для ответа.  

• Создаем DTO для обработки данных.  

• Создаем контроллер для обработки данных.  

• Импортируем необходимые классы и создаем метод для обработки данных.  

• Создаем интерфейс для обработки данных.  

• Имплементируем интерфейс для отправки сообщений в Kafka.  

• Используем класс Future для асинхронных вычислений.  

• Отправляем сообщения в Kafka с использованием Future.  

• Регистрируем действие для выполнения после завершения операции.  

• Проверяем успешность отправки сообщений и выводим информацию на консоль.  

• Метод отправляет сообщения в Kafka асинхронно.  

• В синхронном режиме продюсер ждет ответа от Kafka перед отправкой следующего сообщения.  

• Асинхронный режим подходит для случаев, когда не критично, чтобы все сообщения дошли до адресата.  

• Пример отправки сообщения и получения ответа.  

• В синхронном режиме Kafka отправляет сообщение и ждет ответа перед отправкой следующего.  

• Синхронный режим более медленный, но надежный.  

• Убираем комплект был фьюче и добавляем гет.  

• Гет позволяет получить ответ и не двигаться дальше без него.  

• Добавляем обработку исключений в контроллер.  

• Создаем исключение и обрабатываем его в контроллере.  

• В случае успеха возвращаем стринг, в случае ошибки возвращаем месседж.  

• Запускаем микросервис и проверяем, что сообщения записываются в нужные партиции.  

• Kafka Plugin позволяет отслеживать количество сообщений в каждой партиции.  

• Можно запустить продюсера и отправлять сообщения прямо из плагина.  

• Полезно для проверки прохождения сообщений в микросервисах.  

• Создаем новый проект и настраиваем свойства для Kafka Consumer.  

• Указываем сервер порт, брокеры, лазеры для ключа и значения.  

• Создаем директорию конфиг и класс конфиг для настройки консумера.  

• Создаем метод для создания и настройки Kafka Consumer.  

• Используем бин для управления контейнерами слушателей Kafka.  

• Контейнер управляет работой слушателя и позволяет управлять его работой.  

• Объяснение работы с контейнером Kafka и объектом String.  

• Создание и настройка конфига для Kafka.  

• Завершение конфигурации и переход к созданию event-хандлера.  

• Создание класса с аннотацией @Component.  

• Объявление метода public void для прослушивания событий.  

• Добавление аннотации @KafkaListener и указание топика для прослушивания.  

• Импорт класса из другого микросервиса для корректной работы.  

• Указание правильного пути к классу для корректной работы.  

• Подготовка к получению сообщений.  

• Предусмотрение обработки исключений при невозможности получения события.  

• Реализация обработки исключений в классе KafkaConfig.  

• Тестирование и проверка работы микросервиса.  

• Демонстрация работы микросервиса и передачи сообщений.  

• Призыв к зрителям задавать вопросы и предлагать темы для будущих видео.