@Value("${topology.position.spout.maxpending:#{null}}")
  private Integer spoutMaxPending;

 

@Value("${topology.spout.eventTimeout:3600}")
private int spoutEventTimeout;

相关文章: