Remove useless comment and code.

Signed-off-by: Sanghyeok An <[email protected]>

Author: chickenchickenlove

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

@@ -115,7 +115,6 @@ public abstract class AbstractMessageListenerContainer<K, V>
 
 	private int topicCheckTimeout = DEFAULT_TOPIC_CHECK_TIMEOUT;
 
-	// TODO: HERE ASH
 	private List<RecordInterceptor<K, V>> recordInterceptors = new ArrayList<>();
 
 	private @Nullable BatchInterceptor<K, V> batchInterceptor;

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

@@ -2853,19 +2853,17 @@ private void commitOffsetsIfNeededAfterHandlingError(final ConsumerRecord<K, V>
 		}
 
 		private void recordInterceptAfter(ConsumerRecord<K, V> records, @Nullable Exception exception) {
-			if (!this.commonRecordInterceptors.isEmpty()) {
-				try {
-					if (exception == null) {
-						this.commonRecordInterceptors.forEach(interceptor -> interceptor.success(records, this.consumer));
-					}
-					else {
-						this.commonRecordInterceptors.forEach(interceptor -> interceptor.failure(records, exception, this.consumer));
-					}
+			try {
+				if (exception == null) {
+					this.commonRecordInterceptors.forEach(interceptor -> interceptor.success(records, this.consumer));
 				}
-				catch (Exception e) {
-					this.logger.error(e, "RecordInterceptor.success/failure threw an exception");
+				else {
+					this.commonRecordInterceptors.forEach(interceptor -> interceptor.failure(records, exception, this.consumer));
 				}
 			}
+			catch (Exception e) {
+				this.logger.error(e, "RecordInterceptor.success/failure threw an exception");
+			}
 		}
 
 		private void invokeOnMessage(final ConsumerRecord<K, V> cRecord) {