Added meta-annotation support to RetryableTopic

Author: fablakeson

spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java

@@ -41,7 +41,7 @@
  *
  * @see org.springframework.kafka.retrytopic.RetryTopicConfigurer
  */
-@Target({ ElementType.METHOD })
+@Target({ ElementType.METHOD, ElementType.ANNOTATION_TYPE })
 @Retention(RetentionPolicy.RUNTIME)
 @Documented
 public @interface RetryableTopic {

spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationProviderTests.java

@@ -25,6 +25,10 @@
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
 
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
 import java.lang.reflect.Method;
 import java.util.Collections;
 
@@ -61,6 +65,8 @@ class RetryTopicConfigurationProviderTests {
 
 	private final Method nonAnnotatedMethod = getAnnotatedMethod("nonAnnotatedMethod");
 
+	private final Method metaAnnotatedMethod = getAnnotatedMethod("metaAnnotatedMethod");
+
 	private Method getAnnotatedMethod(String methodName) {
 		try {
 			return  this.getClass().getDeclaredMethod(methodName);
@@ -136,6 +142,20 @@ void shouldFindNone() {
 
 	}
 
+	@Test
+	void shouldProvideFromMetaAnnotation() {
+
+		// setup
+		willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
+
+		// given
+		RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);
+		RetryTopicConfiguration configuration = provider.findRetryConfigurationFor(topics, metaAnnotatedMethod, bean);
+
+		// then
+		then(this.beanFactory).should(times(0)).getBeansOfType(RetryTopicConfiguration.class);
+
+	}
 
 	@Test
 	void shouldNotConfigureIfBeanFactoryNull() {
@@ -157,4 +177,14 @@ public void annotatedMethod() {
 	public void nonAnnotatedMethod() {
 		// NoOps
 	}
+
+	@Target({ElementType.METHOD})
+	@Retention(RetentionPolicy.RUNTIME)
+	@RetryableTopic
+	static @interface MetaAnnotatedRetryableTopic { }
+
+	@MetaAnnotatedRetryableTopic
+	public void metaAnnotatedMethod() {
+		// NoOps
+	}
 }