Изменение расписания для функции Supplier в примере Spring Cloud kafka

Question

Я пытаюсь изменить пример отправителя в этом учебнике Spring Cloud Stream , чтобы изменить интервал отправки по умолчанию.

Пример был обновлен для использования функционал Supplier и удалил аннотации @EnableScheduling\@Scheduled, но я не могу понять, как изменить интервал расписания в новой версии - вот что я безуспешно пробовал:

@Configuration
@EnableScheduling
public class UsageDetailSender {

    private String[] users = {"user1", "user2", "user3", "user4", "user5"};

    @Bean
    @Scheduled(fixedDelay = 3000)
    public Supplier<UsageDetail> sendEvents() {
        return () -> {
            UsageDetail usageDetail = new UsageDetail();
            usageDetail.setUserId(this.users[new Random().nextInt(5)]);
            usageDetail.setDuration(new Random().nextInt(300));
            usageDetail.setData(new Random().nextInt(700));
            return usageDetail;
        };
    }
}

Как мне изменить возвращенный поставщик обновлять каждые 3 секунды?

Answer 1

Вам необходимо предоставить свойства конфигурации опросчика.

См. Документы здесь: https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.4.RELEASE/reference/html/spring-cloud-stream.html#_polling_configuration_properties

Итак, для вашего every 3s это может быть так:

spring.cloud.stream.poller.fixedDelay=3000