Мне поручено использовать Spring Cloud Stream (с привязками Kafka). Проходя через Quick Start Spring Cloud Stream и судя по используемому им файлу конфигурации, LogSinkConfiguration , кажется, что здесь рекомендуется использовать шаблоны Spring Integration, например, @ServiceActivator(inputChannel = Sink.INPUT)
для подключения квходной канал. Однако все учебники, которые я нашел, используют другой набор аннотаций из библиотеки Spring Cloud Stream (по сравнению с Spring Integration), то есть @StreamListener(Processor.INPUT)
в это пошаговое руководство.
Такчто лучше / новее / предпочтительнее (то есть что такое "лучшая практика"). Должен ли я использовать SI для настройки приемника, используя @ServiceActivator(inputChannel = Sink.INPUT)
или альтернативный @StreamListener(Processor.INPUT)
. Являются ли эти два метода подключения приемника практически одинаковыми или есть преимущества использования одного из них над другим?