Fix Compiler Warnings

Also fix javadoc for previous commit.

Author: garyrussell

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

@@ -310,9 +310,11 @@
 
 	/**
 	 * Static information that will be added as a header with key
-	 * {@link org.springframework.kafka.support.KafkaHeaders#LISTENER_INFO}. This can be used, for example, in a
-	 * {@link org.springframework.kafka.listener.RecordInterceptor}, {@link RecordFiorg.springframework.kafka.listener.adapter.RecordFilterStrategylterStrategy} or the listener itself, for
-	 * any purposes.
+	 * {@link org.springframework.kafka.support.KafkaHeaders#LISTENER_INFO}. This can be
+	 * used, for example, in a
+	 * {@link org.springframework.kafka.listener.RecordInterceptor},
+	 * {@link org.springframework.kafka.listener.adapter.RecordFilterStrategy} or the
+	 * listener itself, for any purposes.
 	 * <p>
 	 * SpEL {@code #{...}} and property place holders {@code ${...}} are supported, but it
 	 * must resolve to a String or `byte[]`.

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

@@ -643,6 +643,7 @@ private void resolveContentTypeConverter(MethodKafkaListenerEndpoint<?, ?> endpo
 		}
 	}
 
+	@SuppressWarnings({ "rawtypes", "unchecked" })
 	private void resolveFilter(MethodKafkaListenerEndpoint<?, ?> endpoint, KafkaListener kafkaListener) {
 		Object filter = resolveExpression(kafkaListener.filter());
 		if (filter instanceof RecordFilterStrategy) {

spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java

@@ -395,6 +395,7 @@ public C createListenerContainer(KafkaListenerEndpoint endpoint) {
 		return instance;
 	}
 
+	@SuppressWarnings("deprecation")
 	private void configureEndpoint(AbstractKafkaListenerEndpoint<K, V> aklEndpoint) {
 		if (aklEndpoint.getRecordFilterStrategy() == null) {
 			JavaUtils.INSTANCE

spring-kafka/src/main/java/org/springframework/kafka/listener/ExceptionClassifier.java

@@ -134,7 +134,9 @@ public final void addRetryableExceptions(Class<? extends Exception>... exception
 		add(true, exceptionTypes);
 	}
 
-	private void add(boolean classified, Class<? extends Exception>... exceptionTypes) {
+	@SafeVarargs
+	@SuppressWarnings("varargs")
+	private final void add(boolean classified, Class<? extends Exception>... exceptionTypes) {
 		Assert.notNull(exceptionTypes, "'exceptionTypes' cannot be null");
 		Assert.noNullElements(exceptionTypes, "'exceptionTypes' cannot contain nulls");
 		for (Class<? extends Exception> exceptionType : exceptionTypes) {

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/RetryTopicConfigurer.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2021 the original author or authors.
+ * Copyright 2018-2022 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -371,6 +371,7 @@ private EndpointHandlerMethod getDltEndpointHandlerMethodOrDefault(EndpointHandl
 		return dltEndpointHandlerMethod != null ? dltEndpointHandlerMethod : DEFAULT_DLT_HANDLER;
 	}
 
+	@SuppressWarnings("deprecation")
 	private KafkaListenerContainerFactory<?> resolveAndConfigureFactoryForMainEndpoint(
 			KafkaListenerContainerFactory<?> providedFactory,
 			String defaultFactoryBeanName, RetryTopicConfiguration configuration) {
@@ -386,6 +387,7 @@ private KafkaListenerContainerFactory<?> resolveAndConfigureFactoryForMainEndpoi
 							configuration.forContainerFactoryConfigurer());
 	}
 
+	@SuppressWarnings("deprecation")
 	private KafkaListenerContainerFactory<?> resolveAndConfigureFactoryForRetryEndpoint(
 			KafkaListenerContainerFactory<?> providedFactory,
 			String defaultFactoryBeanName,