Я изо всех сил пытаюсь понять, как я должен go тестировать приложение, которое использует 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
Как мне go это протестировать? Если бы я использовал @StreamListener и список каналов, я бы сделал что-то вроде этого:
channels.uppercase().send(MessageBuilder.withPayload("test").build());
messageCollector.forChannel(channels.uppercaseOutput()).poll(5, TimeUnit.SECONDS);
Однако для Spring Cloud Function это не так. Любая помощь очень приветствуется, так как я ничего не могу найти в официальных документах или образцах!