/
NikolayVasiljev
/
Project
Обзор
Документация
Войти
/
NikolayVasiljev
/
Project
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
feature
src/main/java/org/example/notesystem/service/KafkaConsumerService.java
21 строка
563 B
VasiljevNik
My fourth commit
04 авг 2025, 16:30
04 авг 2025, 16:30
1d611e1
Код
Авторство
О чём код?
package org.example.notesystem.service; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Service; /** * Сервис для обработки сообщений из Kafka. */ @Service public class KafkaConsumerService { /** * Обработка входящих сообщений. */ @KafkaListener(topics = "notes_topic", groupId = "notes_group") public void listen(String message) { System.out.println("Получено сообщение из Kafka: " + message); } }