Динамическое создание слушателей в Kafka
План
Создадим шаблонный класс через реализацию интерфейса MessageListener.
Создадим KafkaListenerEndpoint с помощью шаблона.
Зарегестрируем эндпоинт в KafkaListenerEndpointRegistry.
Создадим окружение для тестирования.
Протестируем решение.
Заключение.
https://habr.com/ru/articles/758958/
👉@BookJava
Post #2686
2.15K
- 👍 4