Функция Spring Cloud и Kafka

Я изо всех сил пытаюсь понять, как мне следует тестировать приложение, которое использует Kafka Binder, а также использует функцию Spring Cloud.

Давайте воспользуемся этим очень простым примером:

@SpringBootApplication
public class DemoKafkaApplication {

public static void main(String[] args) {
    SpringApplication.run(DemoKafkaApplication.class, args);
}

@Bean
public Function<String, String> uppercase() {
    return value -> value.toUpperCase();
}

}

И в моем application.yaml:

spring.cloud:
  stream:
    function:
      definition: uppercase
    bindings:
      uppercase-in-0:
      destination:  uppercase-topic

Как мне это проверить? Если бы я использовал @StreamListener и список каналов, я бы сделал что-то вроде этого:

 channels.uppercase().send(MessageBuilder.withPayload("test").build());

 messageCollector.forChannel(channels.uppercaseOutput()).poll(5, TimeUnit.SECONDS);

Однако для Spring Cloud Function это не так. Любая помощь очень приветствуется, так как я ничего не могу найти в официальных документах или образцах!