Revert 2 commits.

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

Author: chickenchickenlove

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

@@ -475,28 +475,6 @@ public void setRecordInterceptor(@Nullable RecordInterceptor<K, V> recordInterce
 		this.recordInterceptor = recordInterceptor;
 	}
 
-	/**
-	 * Add an interceptor to be called before calling the record listener
-	 * If the {@link AbstractMessageListenerContainer} is not configured with a
-	 * {@link CompositeRecordInterceptor}, {@link CompositeRecordInterceptor} will be created internally
-	 * and configured to hold the added interceptor.
-	 * Does not apply to batch listeners.
-	 * @param recordInterceptor the interceptor.
-	 * @since 4.0
-	 */
-	public void addRecordInterceptor(RecordInterceptor<K, V> recordInterceptor) {
-		if (this.recordInterceptor instanceof CompositeRecordInterceptor<K, V> compositeRecordInterceptor) {
-			compositeRecordInterceptor.addRecordInterceptor(recordInterceptor);
-		}
-		else if (this.recordInterceptor == null) {
-			this.recordInterceptor = new CompositeRecordInterceptor<>(recordInterceptor);
-		}
-		else {
-			this.recordInterceptor = new CompositeRecordInterceptor<>(this.recordInterceptor,
-																	recordInterceptor);
-		}
-	}
-
 	protected @Nullable BatchInterceptor<K, V> getBatchInterceptor() {
 		return this.batchInterceptor;
 	}

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

@@ -92,12 +92,4 @@ public void afterRecord(ConsumerRecord<K, V> record, Consumer<K, V> consumer) {
 		this.delegates.forEach(del -> del.afterRecord(record, consumer));
 	}
 
-	/**
-	 * Add an {@link RecordInterceptor} to delegates.
-	 * @param recordInterceptor the interceptor.
-	 */
-	public void addRecordInterceptor(RecordInterceptor<K, V> recordInterceptor) {
-		this.delegates.add(recordInterceptor);
-	}
-
 }