Spring-Cloud-DataFlow-Stream Source не работает согласно настройке cron, а работает только один раз - PullRequest
1 голос
/ 29 января 2020

Я разработал данные Spring Cloud, которые у меня есть Source - Transform - Sink, но источник не собирается каждые 3 минуты, у меня есть этот как application.properties -> poller.cron=1-59/2 * * * * *

Но, похоже, он делает только один раз вместо запуска источника для преобразования в сток каждые 3 минуты. Любая помощь ценится

@SpringBootApplication
@EnableBinding(Source.class)
public class FetchFromDbApplication {
    Logger logger = LoggerFactory.getLogger(FetchFromDbApplication.class);

    @Autowired
    CustomerService customerService;

    @Bean
    @InboundChannelAdapter(
            value = Source.OUTPUT,
            poller = @Poller(cron = "${poller.cron}", maxMessagesPerPoll = "1")
    )
    public MessageSource<List<Customer>> processCustomer() { this one will run the query and fetch the customers to transform and then to sink}..
...