diff --git a/nakadi-producer-spring-boot-starter/src/main/java/org/zalando/nakadiproducer/NakadiProducerAutoConfiguration.java b/nakadi-producer-spring-boot-starter/src/main/java/org/zalando/nakadiproducer/NakadiProducerAutoConfiguration.java index 0ad70345..87af2c5f 100644 --- a/nakadi-producer-spring-boot-starter/src/main/java/org/zalando/nakadiproducer/NakadiProducerAutoConfiguration.java +++ b/nakadi-producer-spring-boot-starter/src/main/java/org/zalando/nakadiproducer/NakadiProducerAutoConfiguration.java @@ -18,6 +18,7 @@ import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Import; import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; +import org.springframework.scheduling.annotation.EnableScheduling; import org.zalando.fahrschein.NakadiClient; import org.zalando.nakadiproducer.eventlog.EventLogWriter; import org.zalando.nakadiproducer.eventlog.impl.EventLogRepository; @@ -39,6 +40,7 @@ @Configuration @AutoConfigureAfter(name="org.zalando.tracer.spring.TracerAutoConfiguration") +@EnableScheduling public class NakadiProducerAutoConfiguration { @ConditionalOnMissingBean({NakadiPublishingClient.class, NakadiClient.class})