我正在使用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设计的,但我使用了注解。
1条答案
按热度按时间gudnpqoy1#
在本例中,是的,只定义一个
TaskScheduler
bean就可以了。