Какая функциональная модель используется в современном Spring Cloud Stream?

До версии 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); реактивные варианты для потоков.