Я пытаюсь реализовать реактивный потребитель Kafka в своем загрузочном приложении Spring и рассматриваю следующие примеры:
https://github.com/reactor/reactor-kafk ... r/reactor- kafka-samples/src/main/java/reactor/kafka/samples/SampleScenarios.java
и похоже, что в реактивной kafka пока нет поддержки Spring
Я понимаю, как прослушиватели Kafka работают в нереактивном API Kafka в Spring: самое простое решение — настроить bean-компоненты для ConcurrentKafkaListenerContainerFactory и ConsumerFactory, затем использовать аннотацию @KafkaListener и вуаля
Но Я сейчас не уверен, как правильно использовать реактивную Kafka в Spring.
По сути, мне нужен прослушиватель темы. Должен ли я создать какой-то собственный цикл или планировщик?
Или, может быть, я что-то упускаю. Может ли кто-нибудь поделиться своими знаниями и передовым опытом?
Подробнее здесь: https://stackoverflow.com/questions/650 ... pplication
