Функциональная модель (Spring Cloud Stream 3+): обработчики — **бины java.util.function**: Consumer<T> читает, Function<T, R> читает и пишет, Supplier<T> публикует. Аннотации @EnableBinding, @StreamListener удалены.
sottoprocess-in-0, process-out-0spring.cloud.function.definition=process;auditА ещё Реактивный вариант: Function<Flux<T>, Flux<R>>
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
До версии 3 использовали @EnableBinding, каналы и @StreamListener; сейчас это удалено.
Функциональный стиль:
@Bean
Function<OrderCreated, InvoiceRequested> billing() {
return order -> new InvoiceRequested(order.id(), order.total());
}
@Bean
Consumer<InvoicePaid> notify() { return paid -> mailer.send(paid); }spring.cloud.function.definition: billing;notify
spring.cloud.stream.bindings:
billing-in-0.destination: orders
billing-out-0.destination: invoices
notify-in-0: { destination: payments, group: notifications }Отправка вне функции — streamBridge.send("invoices-out-0", payload) (например, из REST-контроллера).
Плюсы: обработчики — обычные функции, легко тестировать без брокера; композиция (billing|enrich); реактивные варианты для потоков.
Один верный вариант. Подумайте, потом откройте ответ.
Binder abstraction, functional model, bindings, consumer groups, partitioning и trade-offs поверх Kafka/RabbitMQ.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.