小编whi*_*cke的帖子

我正在将 Kafka 用于微服务项目。每当我将记录保存到数据库时，我都想调用一个事件。我一直在看有关 Spring Cloud Stream 的教程。他们都在使用@EnableBinding、@Input、@Output 注释。当我尝试使用它们时，它说它们已被弃用。我正在使用 spring 初始值设定项。发行说明说我应该使用供应商、消费者和函数，而不是像输入、输出和流程这样的旧方法。

@Bean
public Supplier<String> toUpperCase() {
    return () -> {
        return "hello from supplier";
    };
}

当我使用这样的供应商时，它每秒生成一条消息，因为它也在教程中突出显示。我不希望它每秒钟都发布一次。我希望它在我想要的时候发布。它说我应该调用它的 get() 方法，但我不知道如何调用。教程使用不推荐使用的函数来实现这样的功能。如何在没有弃用函数的情况下实现这种行为，或者如何使用 EnableBinder 注释而不说它已被弃用？