Блог

Приложение запускается, создает разделы в GCP (можно увидеть в консоли GCP), а затем останавливается через несколько секунд (без исключений или ошибок).:

 @SpringBootApplication
public class PubsubApplication {

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

@Bean
public Function<Person, Person> uppercase() {
    return p -> {
        System.out.println("Received: "   p);
        p.setName(p.getName().toUpperCase());
        return p;
    };
}

public static class Person {
    private String name;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "Person [name="   name   "]";
    }

  }
}
 

применение.свойства:

 spring.cloud.stream.function.bindings.upper-in-0=person-in
spring.cloud.stream.function.bindings.upper-out-0=person-out