spring RetryTopicConfigurationSupport生成异常:需要RetryTopicSchedulerWrapper或TaskScheduler bean

mwyxok5s  于 2023-04-19  发布在  Spring
关注(0)|答案(1)|浏览(138)

我正在使用Sping Boot 3.0.5和Spring Kafka。我想使用RetryTopicConfigurationSupport配置非阻塞主题,如下所示:https://docs.spring.io/spring-kafka/reference/html/#retry-topic-global-settings
我的配置如下所示:

@EnableKafka
@Configuration
public class RetryTopicsConfig extends RetryTopicConfigurationSupport {

    @Override
    protected Consumer<DeadLetterPublishingRecovererFactory> configureDeadLetterPublishingContainerFactory() {

        return dlprf -> dlprf.setRetainAllRetryHeaderValues(false);
    }
}

当应用程序启动时,它会产生:

Caused by: java.lang.IllegalArgumentException: Either a RetryTopicSchedulerWrapper or TaskScheduler bean is required

我做错什么了吗?
当我补充说:

@Bean
public TaskScheduler taskScheduler() {
    return new ThreadPoolTaskScheduler();
}

根据文档(https://docs.spring.io/spring-kafka/reference/html/#programmatic-construction),它是为Programmatic Construction设计的,但我使用了注解。

gudnpqoy

gudnpqoy1#

在本例中,是的,只定义一个TaskScheduler bean就可以了。

相关问题