这是相关源码佐证，你能看懂吧： public RetryTopicConfiguration findRetryConfigurationFor(String[] topics, Method method, Object bean) { RetryableTopic annotation = AnnotationUtils.findAnnotation(method, RetryableTopic.class); return annotation != null ? new RetryableTopicAnnotationProcessor(this.beanFactory, this.resolver, this.expressionContext) .processAnnotation(topics, method, annotation, bean) : maybeGetFromContext(topics); } private EndpointHandlerMethod getDltProcessor(Method listenerMethod, Object bean) { Class<?> declaringClass = listenerMethod.getDeclaringClass(); return Arrays.stream(ReflectionUtils.getDeclaredMethods(declaringClass)) .filter(method -> AnnotationUtils.findAnnotation(method, DltHandler.class) != null) .map(method -> RetryTopicConfigurer.createHandlerMethodWith(bean, method)) .findFirst() .orElse(RetryTopicConfigurer.DEFAULT_DLT_HANDLER); } public RetryTopicConfiguration processAnnotation(String[] topics, Method method, RetryableTopic annotation, Object bean) { Long resolvedTimeout = resolveExpressionAsLong(annotation.timeout(), "timeout", false); long timeout = RetryTopicConstants.NOT_SET; if (resolvedTimeout != null) { timeout = resolvedTimeout; } List<Class<? extends Throwable>> includes = resolveClasses(annotation.include(), annotation.includeNames(), "include"); List<Class<? extends Throwable>> excludes = resolveClasses(annotation.exclude(), annotation.excludeNames(), "exclude"); boolean traverse = false; if (StringUtils.hasText(annotation.traversingCauses())) { Boolean traverseResolved = resolveExpressionAsBoolean(annotation.traversingCauses(), "traversingCauses"); if (traverseResolved != null) { traverse = traverseResolved; } else { traverse = includes.size() > 0 || excludes.size() > 0; } } Boolean autoStartDlt = null; if (StringUtils.hasText(annotation.autoStartDltHandler())) { autoStartDlt = resolveExpressionAsBoolean(annotation.autoStartDltHandler(), "autoStartDltContainer"); } return RetryTopicConfigurationBuilder.newInstance() .maxAttempts(resolveExpressionAsInteger(annotation.attempts(), "attempts", true)) .customBackoff(createBackoffFromAnnotation(annotation.backoff(), this.beanFactory)) .retryTopicSuffix(resolveExpressionAsString(annotation.retryTopicSuffix(), "retryTopicSuffix")) .dltSuffix(resolveExpressionAsString(annotation.dltTopicSuffix(), "dltTopicSuffix")) .dltHandlerMethod(getDltProcessor(method, bean)) .includeTopics(Arrays.asList(topics)) .listenerFactory(resolveExpressionAsString(annotation.listenerContainerFactory(), "listenerContainerFactory")) .autoCreateTopics(resolveExpressionAsBoolean(annotation.autoCreateTopics(), "autoCreateTopics"), resolveExpressionAsInteger(annotation.numPartitions(), "numPartitions", true), resolveExpressionAsShort(annotation.replicationFactor(), "replicationFactor", true)) .retryOn(includes) .notRetryOn(excludes) .traversingCauses(traverse) .useSingleTopicForFixedDelays(annotation.fixedDelayTopicStrategy()) .dltProcessingFailureStrategy(annotation.dltStrategy()) .autoStartDltHandler(autoStartDlt) .setTopicSuffixingStrategy(annotation.topicSuffixingStrategy()) .timeoutAfter(timeout) .create(getKafkaTemplate(resolveExpressionAsString(annotation.kafkaTemplate(), "kafkaTemplate"), topics)); } 问你还真不如自己看源码