Spring Cloud Stream 函数式Supplier未按预期定期轮询触发问题排查

问题排查&修复方案 #

1. 优先排查日志位置误判问题

你当前代码里的日志打印在了Supplier Bean的创建方法中，该方法仅会在Spring上下文初始化Bean时执行1次，实际每次调度触发的是返回的lambda中的get()方法，日志位置错误会导致你误以为调度没有执行。
修改代码验证：

@Component
@Slf4j
public class EventSource {

    @Bean
    public Supplier<String> generateEvents() {
        log.debug("Supplier Bean 初始化完成，仅执行一次");
        return () -> {
            // 每次调度都会执行该分支逻辑
            log.debug("生成事件发布到Kafka");
            return "Hi I'm an event";
        };
    }

}

2. 检查是否缺少调度依赖

Spring Cloud Stream 对普通Supplier的自动调度依赖spring-boot-starter-integration组件提供的轮询器能力，未引入该依赖会导致调度仅执行一次后停止。
确认引入依赖（以Maven为例）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>

3. 明确配置调度间隔

默认调度间隔为1000ms，若配置被修改为非法值会导致调度终止，可在application.yml中主动指定调度规则：

spring:
  cloud:
    stream:
      poller:
        fixed-delay: 1000 # 单位ms，每1秒调度一次
        initial-delay: 0 # 启动后立即开始首次调度
    function:
      definition: generateEvents
    stream:
      bindings:
        generateEvents-out-0:
          destination: eventsTopic

4. 其他排查点

• 若存在多个函数定义，确认spring.cloud.function.definition中已包含generateEvents，多函数用;分隔
• 可将org.springframework.cloud.stream日志级别调整为DEBUG，查看轮询器调度日志定位异常

内容的提问来源于stack exchange，提问作者jned